[KAFKA-6773] Kafka consumer without group.id crashes when requesting offset on a topic-partition

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Component/s: core
• Assignee: Jason Gustafson
• Reporter: Konstantine Karantasis
• Created: 10/Apr/18 22:19
• Updated: 12/Apr/18 01:22
• Resolved: 12/Apr/18 01:22

Description

After recent changes, when a KafkaConsumer requests the current offset on a topic partition (e.g. via a call to position), the following exception is thrown if the consumer doesn't belong to a consumer group ( group.id is unset): 

org.apache.kafka.common.KafkaException: Unexpected error in fetch offset response: The configured groupId is invalid         at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetFetchResponseHandler.handle(ConsumerCoordinator.java:835)         at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetFetchResponseHandler.handle(ConsumerCoordinator.java:818)         at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:822)         at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:802)         at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)         at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)         at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)         at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:574)         at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:389)         at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:292)         at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232)         at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:192)         at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.fetchCommittedOffsets(ConsumerCoordinator.java:469)         at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.refreshCommittedOffsetsIfNeeded(ConsumerCoordinator.java:446)         at org.apache.kafka.clients.consumer.KafkaConsumer.updateFetchPositions(KafkaConsumer.java:1788)         at org.apache.kafka.clients.consumer.KafkaConsumer.position(KafkaConsumer.java:1429)

 

Issue Links

• links to: GitHub Pull Request #4851