[
https://issues.apache.org/jira/browse/KAFKA-7263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895480#comment-16895480
]
Guozhang Wang edited comment on KAFKA-7263 at 7/29/19 5:45 PM:
---------------------------------------------------------------
[~mbarbon] [~simplyamuthan] Thanks for the report, I will continue the
investigation on KAFKA-8104. Could you guys share as much of your logs as
possible on that ticket (I saw the original reporter has uploaded some log
files on client side, but in this case broker-side logs are even more
important)?
was (Author: guozhang):
[~mbarbon] [~simplyamuthan] Thanks for the report, I will continue the
investigation on KAFKA-8104. Could you guys share as much of your logs as
possible on that ticket (I saw Mattia has uploaded some log files on client
side, but in this case broker-side logs are even more important)?
> 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)
