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.

Reply via email to