我也遇到了一样的问题,使用的是 Kafka version: 2.2.1-cdh6.3.1 版本,我是某一个topic有两个partition处于离线状态,之后重启了kafka集群,然后就产生了大量重复的数据,不知道什么原因
 
                        
                        
                    
                    
                    
                    
                    
                    
                换了2.5官网版本搭了一个测试服务没有出现这个问题了。。不知道cdh里面集成的是哪一个版本的kafka,实在不行只能换版本重新部署了,,我是刚接触kafka没多久的,,这个问题真是把我愁坏了