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