@Neha, Can you share suggested consumer side GC settings? On Wed, Nov 12, 2014 at 5:31 PM, Neha Narkhede <neha.narkh...@gmail.com> wrote:
> Does this help? > > https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Whyaretheremanyrebalancesinmyconsumerlog > ? > > On Wed, Nov 12, 2014 at 3:53 PM, Chen Wang <chen.apache.s...@gmail.com> > wrote: > > > Hi there, > > My kafka client is reading a 3 partition topic from kafka with 3 threads > > distributed on different machines. I am seeing frequent owner changes on > > the topics when running: > > bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group > > my_test_group --topic mytopic -zkconnect localhost:2181 > > > > The owner kept changing once a while, but I didn't see any exceptions > > thrown from the consumer side. When checking broker log, its full of > > INFO Closing socket connection to /IP. (kafka.network.Processor) > > > > Is this expected behavior? If so, how can I tell when the leader is > > imbalanced, and rebalance is triggered? > > Thanks, > > Chen > > >
