1.扩容在新的物理机上安装kafka程序，修改config/server.properties文件里的broker.id必须在集群中唯一，修改其他必要的配置项，其中zookeeper.connect配置项，写上kafka集群现在使用的zookee...

报错日志： xx ms has passed since last append / xx ms has passed since batch creation plus linger time / ms has passed since las...

最近用kafka中间件处理消息报错了一些异常信息，想通过客户端连接kafka看一下信息的消费处理。不加密的Kafka通过Tool连接Client特别简单，网上也有很多官方教材。这里就不一一描述了。但是加密过的Kafka连接时，Tool工具会出现下...

非kerberos环境 1. 准备 2. produce demo 3. consumer demo kerberos环境 1. 准备 2. produce demo 3. consume demo lite2.0的kafka集群...