[
https://issues.apache.org/jira/browse/KAFKA-20598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
majialong reassigned KAFKA-20598:
---------------------------------
Assignee: majialong (was: Chia-Ping Tsai)
> 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: majialong
> Priority: Minor
>
> {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)
