我们kafka有一个topic,查看kafka的数据目录,里面的.log文件内容一直是重复的,使用kafka客户端模拟生产者发送一条消息,也能看到这个log文件一直重复这一条消息,是怎么回事?如果起消费者消费,查看日志就一直消费,导致日志文件特别大!
问题已经解决,是我们程序的bug,有一个消费者一直再消费,然后又重新发给kafka集群导致的.之前没发生这种情况是那个消费者收不到消息.
谢谢分享。
你的答案