FWIW - (for some distant observer):
I think my topic / consumer was too slow for the default commit interval. I
added these lines to the above config and it seems to be working ok:
// These are likely the default but Im adding them ... anyway...
consumerProperties.put("enable.auto.commit", "true");
consumerProperties.put("auto.commit.interval.ms", "1000");
// this is the critical view (I think)
consumerProperties.put("max.poll.records", "10");
On Tue, Jan 10, 2017 at 8:55 AM, Jon Yeargers <jon.yearg...@cedexis.com>
wrote:
> 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
>
