Hi all, I'm encountering a problem where i'm getting far too many duplicate messages being sent to my kafka setup (statically, using broker.list), being picked up by zk-based consumers.
I've provided my test classes here and the kafka/zk versions i'm using to run them and my servers: *client side*: producer: git://gist.github.com/4089354.git consumer: git://gist.github.com/4089369.git *jars*: kafka-0.7.2 *server side*: 5 kafka servers, zk servers on 3 of those 1 partition per test topic per server *server versions*: kafka-0.7.1 zookeeper-3.4.3 Any advice would be greatly appreciated. Thank you, Mark
