[
https://issues.apache.org/jira/browse/KAFKA-8891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SAIRAM KODURU updated KAFKA-8891:
---------------------------------
Description:
we are using 0.11.0.2 kafka client in our application.
we have observed the *below mentioned error* and got flooded with logs in
*crores*.
java.lang.IllegalStateException: Coordinator selected invalid assignment
protocol: null
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:218)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:367)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:316)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:297)
at
org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1078)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1043)
But we are not able to reproduce the issue again ?
First would like to know ,what are the possibilities of this error ?
Priority: Major (was: Minor)
Summary: invalid assignment protocoljava.lang.IllegalStateException:
Coordinator selected invalid assignment protocol: null (was: invalid
assignment protocol)
> invalid assignment protocoljava.lang.IllegalStateException: Coordinator
> selected invalid assignment protocol: null
> ------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-8891
> URL: https://issues.apache.org/jira/browse/KAFKA-8891
> Project: Kafka
> Issue Type: Bug
> Reporter: SAIRAM KODURU
> Priority: Major
>
> we are using 0.11.0.2 kafka client in our application.
> we have observed the *below mentioned error* and got flooded with logs in
> *crores*.
> java.lang.IllegalStateException: Coordinator selected invalid assignment
> protocol: null
> at
> org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:218)
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:367)
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:316)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:297)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1078)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1043)
>
> But we are not able to reproduce the issue again ?
> First would like to know ,what are the possibilities of this error ?
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
