这家伙太懒,什么都没留下
我也遇到了一样的问题,使用的是 Kafka version: 2.2.1-cdh6.3.1 版本,我是某一个topic有两个partition处于离线状态,之后重启了kafka集群,然后就产生了大量重复的数据,不知道什么原因
你在观察观察吧,你这个算是黑盒,看不到怎么运行的。
cdh的版本是6.3.2-1.cdh6.3.2.p0.1605554,kafka是cdh安装时候自带的
换了2.5官网版本搭了一个测试服务没有出现这个问题了。。不知道cdh里面集成的是哪一个版本的kafka,实在不行只能换版本重新部署了,,我是刚接触kafka没多久的,,这个问题真是把我愁坏了
没用消费者命令。。用了一个工具叫kafkaTool来监视主题下的消息