[jira] [Comment Edited] (KAFKA-8715) Static consumer cannot join group due to ERROR in broker
[
https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898841#comment-16898841
]
neeraj edited comment on KAFKA-8715 at 8/5/19 5:23 AM:
---
[~bchen225242]We are looking forward to use static consumer, when is 2.3.1
release planned ?
was (Author: neeraj.bhatt):
We are looking forward to use static consumer, when is 2.3.1 release planned ?
> 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
> Components: consumer, streams
>Affects Versions: 2.3.0
>Reporter: Raman Gupta
>Assignee: Boyang Chen
>Priority: Critical
> Labels: blocker
> Fix For: 2.3.1
>
>
> 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.
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:599)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:527)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:978)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:958)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:578)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:388)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:294)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:161)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.ensureFreshMetadata(ConsumerNetworkClient.java:172)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:346)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1251)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1201)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:941)
> ~[kafka-streams-2.3.0.jar:?]
> at
> org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:846)
> ~[kafka-streams-2.3.0.jar:?]
> at
> org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:805)
> ~[kafka-streams-2.3.0.jar:?]
> at
> org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:774)
> [kafka-streams-2.3.0.jar:?]
> ]]
> {code}
> On the broker, I see this error:
> {code}
> [2019-07-25 08:14:11,978] ERROR [KafkaApi-1] Error when handling request:
>
[jira] [Comment Edited] (KAFKA-8715) Static consumer cannot join group due to ERROR in broker
[
https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893117#comment-16893117
]
Raman Gupta edited comment on KAFKA-8715 at 7/25/19 8:45 PM:
-
[~bchen225242] No it isn't happening all the time. Interestingly, I have two
different instances of the same 2.3.0 client code running against the same
2.3.0 Kafka broker. The only difference between them is the configured name of
the group, and the topics being consumed. One of them get this error, the other
does not.
In addition, it initially used to work with both consumer groups. It stopped
working for one group when I restarted the cluster in order to apply an
unrelated configuration change.
was (Author: rocketraman):
[~bchen225242] No it isn't happening all the time. Interestingly, I have two
different instances of the same 2.3.0 client code running against the same
2.3.0 Kafka broker. The only difference between them is the configured name of
the group, and the topics being consumed. One of them get this error, the other
does not.
> 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
>Assignee: Boyang Chen
>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.
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:599)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:527)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:978)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:958)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:578)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:388)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:294)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:161)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.ensureFreshMetadata(ConsumerNetworkClient.java:172)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:346)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1251)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1201)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:941)
>
[jira] [Comment Edited] (KAFKA-8715) Static consumer cannot join group due to ERROR in broker
[
https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893117#comment-16893117
]
Raman Gupta edited comment on KAFKA-8715 at 7/25/19 8:44 PM:
-
[~bchen225242] No it isn't happening all the time. Interestingly, I have two
different instances of the same 2.3.0 client code running against the same
2.3.0 Kafka broker. The only difference between them is the configured name of
the group, and the topics being consumed. One of them get this error, the other
does not.
was (Author: rocketraman):
[~bchen225242] No it isn't happening all the time. Interestingly, I have two
different instances of the same 2.3.0 client code running against the same
2.3.0 Kafka broker. The only difference between them is the configured name of
the group, and the topics being consumed.
> 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
>Assignee: Boyang Chen
>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.
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:599)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:527)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:978)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:958)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:578)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:388)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:294)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:161)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.ensureFreshMetadata(ConsumerNetworkClient.java:172)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:346)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1251)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1201)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:941)
> ~[kafka-streams-2.3.0.jar:?]
> at
> org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:846)
> ~[kafka-streams-2.3.0.jar:?]
> at
>
[jira] [Comment Edited] (KAFKA-8715) Static consumer cannot join group due to ERROR in broker
[
https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893030#comment-16893030
]
Boyang Chen edited comment on KAFKA-8715 at 7/25/19 6:14 PM:
-
Is this happening all time? The code triggers exception is:
{code:java}
instanceId + GroupMetadata.MemberIdDelimiter + currentStateTimestamp.get
{code}
where currentStateTimestamp is defined as:
{code:java}
var currentStateTimestamp: Option[Long] = Some(time.milliseconds())
{code}
So every time we will call timer to get current timestamp, couldn't picture how
this will give none atm. Will try to reproduce the issue in the meantime.
cc [~guozhang] [~hachikuji]
was (Author: bchen225242):
Is this happening all time? The code triggers exception is:
```instanceId + GroupMetadata.MemberIdDelimiter + currentStateTimestamp.get```
where currentStateTimestamp is defined as:
`var currentStateTimestamp: Option[Long] = Some(time.milliseconds())`
So every time we will call timer to get current timestamp, couldn't picture how
this will give none atm. Will try to reproduce the issue in the meantime.
cc [~guozhang] [~hachikuji]
> 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.
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:599)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:527)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:978)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:958)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:578)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:388)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:294)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:161)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.ensureFreshMetadata(ConsumerNetworkClient.java:172)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:346)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1251)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1201)
> ~[kafka-clients-2.3.0.jar:?]
> at
>
[jira] [Comment Edited] (KAFKA-8715) Static consumer cannot join group due to ERROR in broker
[
https://issues.apache.org/jira/browse/KAFKA-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893030#comment-16893030
]
Boyang Chen edited comment on KAFKA-8715 at 7/25/19 6:13 PM:
-
Is this happening all time? The code triggers exception is:
```instanceId + GroupMetadata.MemberIdDelimiter + currentStateTimestamp.get```
where currentStateTimestamp is defined as:
`var currentStateTimestamp: Option[Long] = Some(time.milliseconds())`
So every time we will call timer to get current timestamp, couldn't picture how
this will give none atm. Will try to reproduce the issue in the meantime.
cc [~guozhang] [~hachikuji]
was (Author: bchen225242):
Is this happening all time? The code triggers exception is:
`instanceId + GroupMetadata.MemberIdDelimiter + currentStateTimestamp.get`
where currentStateTimestamp is defined as:
`var currentStateTimestamp: Option[Long] = Some(time.milliseconds())`
So every time we will call timer to get current timestamp, couldn't picture how
this will give none atm. Will try to reproduce the issue in the meantime.
cc [~guozhang] [~hachikuji]
> 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.
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:599)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:527)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:978)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:958)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:578)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:388)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:294)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:161)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.ensureFreshMetadata(ConsumerNetworkClient.java:172)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:346)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1251)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1201)
> ~[kafka-clients-2.3.0.jar:?]
> at
> org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:941)
>
