kafka版本太低，客户端需要切换版本 ...

问题描述： 我之前使用kafka的命令删除了改topic： ./kafka-topics.sh --delete --zookeeper 【zookeeper server】 --topic 【topic name】 kafka是启用了自动创建topic功能的（之气那测试 ...

原文：https://www.marscheng.cn/articles/2020/02/17/1581951053291.html 问题背景 测试大哥反馈，测试环境好多订单还是 processi ...

报错背景： 单机安装了kafka，创建完成主题，启动生产者的时候产生报错现象。报错时持续不断打印日志信息。 报错现象： 报错原因： 获取相关ID为xx的元数据时出错。 报错 ...

1)环境信息： docker版本：17.09，当docker的版本是12.06时，也会报这个错误 [root@localhost ~]# docker --version Docker ve ...

原因是该kafka集群没有设置自动创建 topic，所以spark无法创建该 topic，因此也无法找到该 topic 的metadata 所以解决该问题的方法就是：手动创建该 topic ...

一、发现问题 二、分析问题 .net长时间连接mysql导致超时； 方式一：连接用完后，就关闭连接 方式二：增加C#的执行sqlcommand时间 三、解决问题 增加了这一句，问题解决 ...

1、前言 　　Flink作业提交到Yarn上之后，后续的AM的生成、Job的处理过程和Flink基本没什么关系了，但是为大致了解Flink on yarn的Per-Job模式的整体过程，这里还是将这系列博客归到Flink源码阅读系列了，本系列博客计划三篇。 　　本文着重分析 ...