1.背景
 
今天发现运行flink任务,结果没有消费到任何数据,然后我检查了配置发现正确。然后使用控制台去消费业正确,能正常消费,然后发送数据也能正常发送,但是就是无法使用java或者flink去消费,然后开始是flink无法消费,后来检查无果后,我写了一个Java客户端去去消费,然后还是无法消费。
 
然后去检查topic信息
 
 可以看到topic信息正常,但是还是无法消费,我都怀疑是不是磁盘不够了,看了下是够的,然后怀疑网络,telnet下也是通的。
 
最后都想删除topic重建了。
 
然后我重启了一个kafka节点。然后居然好了。
 
2. 场景再现2
 
在一个集群中建立了topic如下