No consumers for a Kafka topic #2819
-
Team, When I run a command using kafka-consumer-groups.sh to list the current offeset, lag etc for a group, I see no consumer-id attached although there is a lag in a topic. The topic is listened by a service and service is up and running. When I restart the service, the consumer is attached and processed the messages for 7 mins then again the consumer-id became empty and no messages are processed. There are 500 more messages that are yet to be processed I do not see any error in the broker. I have the following config
So why does the consumer detaching from the topic? Any leads are much appreciated and let me know if you need more info. |
Beta Was this translation helpful? Give feedback.
Replies: 1 comment 2 replies
-
Apparently you have some blocking part in your listener logic where you don't return control back to Please, revise the logic of your |
Beta Was this translation helpful? Give feedback.
Apparently you have some blocking part in your listener logic where you don't return control back to
KafkaConsumer
.And since it does not
poll()
any more, the group coordinator treats it as broken and detaches it from the group.Please, revise the logic of your
@KafkaListener
and try to determine where you block.