[KAFKA-9507] AdminClient should check for missing committed offsets

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.5.0, 2.3.2, 2.4.1
• Labels: newbie
• Assignee: David Mao
• Reporter: Jason Gustafson
• Created: 05/Feb/20 20:41
• Updated: 08/Feb/20 00:54
• Resolved: 08/Feb/20 00:54

Description

I noticed this exception getting raised:

Caused by: java.lang.IllegalArgumentException: Invalid negative offset
	at org.apache.kafka.clients.consumer.OffsetAndMetadata.<init>(OffsetAndMetadata.java:50)
	at org.apache.kafka.clients.admin.KafkaAdminClient$24$1.handleResponse(KafkaAdminClient.java:2832)
	at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.handleResponses(KafkaAdminClient.java:1032)
	at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1160)

The AdminClient should check for negative offsets in OffsetFetch responses in the api `listConsumerGroupOffsets`.

Issue Links

• links to: GitHub Pull Request #8057