Hi, I am using new Kafka consumer API ( 0.9.0.0) . I created 100 partitions of a topic and started only one consumer to consume. Many of times , In consumer logs I see lot of rebalancing activity and no object is consumed due to that.
Is this a known issue? Please let me know if some body can help with regard to this. My Consumer config: props.put("zookeeper.session.timeout.ms", "10000"); props.put("rebalance.backoff.ms","10000"); props.put("zookeeper.sync.time.ms","200"); props.put("rebalance.max.retries","10"); props.put("enable.auto.commit", "false"); props.put("consumer.timeout.ms","20000"); props.put("auto.offset.reset", "smallest"); Thanks, Sahitya