Raman Gupta created KAFKA-8715: ---------------------------------- Summary: Static consumer cannot join group due to ERROR in broker Key: KAFKA-8715 URL: https://issues.apache.org/jira/browse/KAFKA-8715 Project: Kafka Issue Type: Bug Affects Versions: 2.3.0 Reporter: Raman Gupta
A streams consumer using a static group instance id is unable to join the group due to an invalid group join -- the consumer gets the error: ``` ERROR stream-thread [x-stream-4a43d5d4-d38f-4cb0-8741-7a6c685abf15-StreamThread-1] Encountered the following unexpected Kafka exception during processing, this usually indicate Streams internal errors: [[EXCEPTION: org.apache.kafka.common.KafkaException: Unexpected error in join group response: The server experienced an unexpected error when processing the request. ``` On the broker, I see this error: ``` [2019-07-25 08:14:11,978] ERROR [KafkaApi-1] Error when handling request: clientId=x-stream-4a43d5d4-d38f-4cb0-8741-7a6c685abf15-StreamThread-1-consumer, correlationId=6, api=JOIN_GROUP, body={group_id=x-stream,session_timeout_ms=10000,rebalance_timeout_ms=300000,member_id=,group_instance_id=lcrzf-1,protocol_type=consumer,protocols=[{name=stream,metadata=java.nio.HeapByteBuffer[pos=0 lim=64 cap=64]}]} (kafka.server.KafkaApis) java.util.NoSuchElementException: None.get at scala.None$.get(Option.scala:366) at scala.None$.get(Option.scala:364) at kafka.coordinator.group.GroupMetadata.generateMemberId(GroupMetadata.scala:368) at kafka.coordinator.group.GroupCoordinator.$anonfun$doUnknownJoinGroup$1(GroupCoordinator.scala:178) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:253) at kafka.coordinator.group.GroupMetadata.inLock(GroupMetadata.scala:209) at kafka.coordinator.group.GroupCoordinator.doUnknownJoinGroup(GroupCoordinator.scala:169) at kafka.coordinator.group.GroupCoordinator.$anonfun$handleJoinGroup$2(GroupCoordinator.scala:144) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:253) at kafka.coordinator.group.GroupMetadata.inLock(GroupMetadata.scala:209) at kafka.coordinator.group.GroupCoordinator.handleJoinGroup(GroupCoordinator.scala:136) at kafka.server.KafkaApis.handleJoinGroupRequest(KafkaApis.scala:1389) at kafka.server.KafkaApis.handle(KafkaApis.scala:124) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:69) at java.base/java.lang.Thread.run(Thread.java:834) ``` -- This message was sent by Atlassian JIRA (v7.6.14#76016)