Single app with single consumer. Pulling ~30 records / min.
When I enter 'kafka-topics ... --new-consumer --group <above group>
--describe' it always tells me "Consumer group <name> is rebalancing".
If I enter "kafka-consumer-offset-checker ...--topic <name> --group <above
name>"it responds with appropriate consumer position(s) but tells me
"owner" is "none".
I know my app is consuming records and if I stop/start it it picks up where
it left off.
Why is it marked as 'rebalancing'?
Consumer setup:
props.put("bootstrap.servers", Main.KAFKA_IP);
props.put("group.id", groupId);
props.put("key.deserializer", StringDeserializer.class.getName());
props.put("value.deserializer", StringDeserializer.class.getName());
props.put("session.timeout.ms", "60000");
props.put("request.timeout.ms", "60001");
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
Using 0.10.1.0 brokers
0.10.2.0-SNAPSHOT (current trunk) as client library
