[
https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raman Gupta updated KAFKA-8715:
-------------------------------
Description:
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:
{code}
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.
{code}
On the broker, I see this error:
{code}
[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)
{code}
was:
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)
```
> 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
> Priority: Critical
>
> 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:
> {code}
> 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.
> {code}
> On the broker, I see this error:
> {code}
> [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)
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
