Chia-Ping Tsai created KAFKA-20598:
--------------------------------------
Summary: Prevent polling unassigned consumer during ConsumerTask
shutdown
Key: KAFKA-20598
URL: https://issues.apache.org/jira/browse/KAFKA-20598
Project: Kafka
Issue Type: Bug
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
{code:java}
[2026-05-19 00:28:21,073] ERROR Error occurred while processing the records
(org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask:153)
java.lang.IllegalStateException: Consumer is not subscribed to any topics or
assigned any partitions
at
org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer.poll(ClassicKafkaConsumer.java:654)
at
org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer.poll(ClassicKafkaConsumer.java:642)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:917)
at
org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask.ingestRecords(ConsumerTask.java:141)
at
org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask.run(ConsumerTask.java:127)
at java.base/java.lang.Thread.run(Thread.java:1583)
{code}
If the ConsumerTask is closed too quickly, the consumer will be polled under no
assignments, which throws an IllegalStateException. I noticed this noisy error
output during integration testing. While it poses no harm to production, it is
still cool (and cleaner) to fix it.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
