[
https://issues.apache.org/jira/browse/KAFKA-7263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894700#comment-16894700
]
Mattia Barbon edited comment on KAFKA-7263 at 7/28/19 1:08 PM:
---------------------------------------------------------------
[~mjsax] for me it is happening with an uniform consumer group; what I have is
a set of consumers that subscribe/unsubscribe from a consumer group depending
on available resources;
it works most of the time, but sometimes one of the consumers throws the error
above. The consumer group is using the default partition assignor.
Also, I'm using KafkaConsumer directly, no Spring or other framework involved.
was (Author: mbarbon):
[~mjsax] for me it is happening with an uniform consumer group; what I have is
a set of consumers that subscribe/unsubscribe from a consumer group depending
on available resources;
it works most of the time, but sometimes one of the consumers throws the error
above. The consumer group is using the default partition assignor.
> Container exception java.lang.IllegalStateException: Coordinator selected
> invalid assignment protocol: null
> -----------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-7263
> URL: https://issues.apache.org/jira/browse/KAFKA-7263
> Project: Kafka
> Issue Type: Bug
> Reporter: laomei
> Priority: Major
>
> We are using spring-kafka and we get an infinite loop error in
> ConsumerCoordinator.java;
> kafka cluster version: 1.0.0
> kafka-client version: 1.0.0
>
> 2018-08-08 15:24:46,120 ERROR
> [org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer]
> - Container exception
> java.lang.IllegalStateException: Coordinator selected invalid assignment
> protocol: null
> at
> org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:217)
> 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:295)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1138)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1103)
> at
> org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:556)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at java.lang.Thread.run(Thread.java:745)
> 2018-08-08 15:24:46,132 INFO
> [org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer]
> - Consumer stopped
> 2018-08-08 15:24:46,230 INFO
> [org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer]
> - Consumer stopped
> 2018-08-08 15:24:46,234 INFO [org.springfram
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
