[KAFKA-16759] Invalid client telemetry transition on consumer close

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 3.7.0, 3.7.1
• Fix Version/s: 3.8.0, 3.7.2
• Assignee: Andrew Schofield
• Reporter: Andrew Schofield
• Created: 14/May/24 08:27
• Updated: 10/Oct/24 14:53
• Resolved: 28/May/24 15:33

Description

Using the console consumer with client telemetry enabled, I hit an invalid state transition when closing the consumer with CTRL-C. The consumer sends a final "terminating" telemetry push which puts the client telemetry reporter into TERMINATING_PUSH_IN_PROGRESS state. When it receives a response in this state, it attempts an invalid state transition.

 

[2024-05-13 19:19:35,804] WARN Error updating client telemetry state, disabled telemetry (org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter)
java.lang.IllegalStateException: Invalid telemetry state transition from TERMINATING_PUSH_IN_PROGRESS to PUSH_NEEDED; the valid telemetry state transitions from TERMINATING_PUSH_IN_PROGRESS are: TERMINATED
	at org.apache.kafka.common.telemetry.ClientTelemetryState.validateTransition(ClientTelemetryState.java:163)
	at org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter$DefaultClientTelemetrySender.maybeSetState(ClientTelemetryReporter.java:827)
	at org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter$DefaultClientTelemetrySender.handleResponse(ClientTelemetryReporter.java:520)
	at org.apache.kafka.clients.NetworkClient$TelemetrySender.handleResponse(NetworkClient.java:1321)
	at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:948)
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:594)
	at org.apache.kafka.clients.consumer.internals.NetworkClientDelegate.poll(NetworkClientDelegate.java:130)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.sendUnsentRequests(ConsumerNetworkThread.java:262)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.cleanup(ConsumerNetworkThread.java:275)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.run(ConsumerNetworkThread.java:95)
[2024-05-13 19:19:35,805] WARN Unable to transition state after successful push telemetry from state TERMINATING_PUSH_IN_PROGRESS (org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter)

Issue Links

• links to: GitHub Pull Request #15957