Hi ,
I am getting the below error messages when consuming the records from the
kafka topic .
o.a.k.c.c.internals.ConsumerCoordinator : Error ILLEGAL_GENERATION
occurred while committing offsets for group test-group.
2016-07-11 22:56:50.314 ERROR 8699 --- [ Thread]
o.a.k.c.c.internals.ConsumerCoordinator : Error ILLEGAL_GENERATION
occurred while committing offsets for group test-group
2016-07-11 22:56:50.315 WARN 8699 --- [Thread]
o.a.k.c.c.internals.ConsumerCoordinator : Auto offset commit failed:
Commit cannot be completed due to group rebalance
2016-07-11 22:56:50.320 ERROR 8699 --- [ Thread]
o.a.k.c.c.internals.ConsumerCoordinator : Error ILLEGAL_GENERATION
occurred while committing offsets for group test-group
2016-07-11 22:56:50.321 WARN 8699 --- [- Thread]
o.a.k.c.c.internals.ConsumerCoordinator : Auto offset commit failed:
2016-07-11 22:56:50.323 INFO 8699 --- [Thread]
o.a.k.c.c.internals.AbstractCoordinator : Attempt to join group test-group
failed due to unknown member id, resetting and retrying.
And I am creating the consumer as follows :
KafkaConsumer<byte[],byte[]> consumer=new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList(topic).
Where props is set with the properties :
props.put("security.protocol", "SASL_PLAINTEXT");
props.put("group.id", groupId);
props.put("bootstrap.servers", "pqrs:9092,xyz:9092");
And kafka client I am using is 0.9.0.1.
Could you please help me to resolve this issue. I have gone through so many
links available over the internet but did not find the useful answers.
Thanks in Advance.
Param.