[ https://issues.apache.org/jira/browse/KAFKA-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jason Gustafson resolved KAFKA-6773. ------------------------------------ Resolution: Fixed Fix Version/s: (was: 1.1.1) (was: 1.2.0) > Kafka consumer without group.id crashes when requesting offset on a > topic-partition > ----------------------------------------------------------------------------------- > > Key: KAFKA-6773 > URL: https://issues.apache.org/jira/browse/KAFKA-6773 > Project: Kafka > Issue Type: Bug > Components: core > Reporter: Konstantine Karantasis > Assignee: Jason Gustafson > Priority: Blocker > > 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): > {code:java} > 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) > {code} > -- This message was sent by Atlassian JIRA (v7.6.3#76005)