Kirk True created KAFKA-17040:
---------------------------------
Summary: Unknown telemetry state: TERMINATED thrown when closing
AsyncKafkaConsumer
Key: KAFKA-17040
URL: https://issues.apache.org/jira/browse/KAFKA-17040
Project: Kafka
Issue Type: Bug
Components: clients, metrics
Affects Versions: 3.9.0
Reporter: Kirk True
An error is occasionally thrown when closing the {{{}AsyncKafkaConsumer{}}}:
{noformat}
[ERROR] 2024-06-20 17:13:54,121 [consumer_background_thread]
org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread
lambda$configureThread$0 - Uncaught exception in thread
'consumer_background_thread':
java.lang.IllegalStateException: Unknown telemetry state: TERMINATED
at
org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter$DefaultClientTelemetrySender.timeToNextUpdate(ClientTelemetryReporter.java:363)
at
org.apache.kafka.clients.NetworkClient$TelemetrySender.maybeUpdate(NetworkClient.java:1392)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:668)
at
org.apache.kafka.clients.consumer.internals.NetworkClientDelegate.poll(NetworkClientDelegate.java:143)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.sendUnsentRequests(ConsumerNetworkThread.java:299)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.cleanup(ConsumerNetworkThread.java:318)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.run(ConsumerNetworkThread.java:105){noformat}
The issue appears to be that the {{TERMINATED}} state is not expected in the
switch statement inside
[timeToNextUpdate()|https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java#L307].
As an aside, the error message might make more sense to be written as
"{_}Unexpected{_} telemetry state" instead of "{_}Unknown{_} telemetry state"
since {{TERMINATED}} is a known state, but heretofore unexpected.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
