[ 
https://issues.apache.org/jira/browse/KAFKA-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16433134#comment-16433134
 ] 

ASF GitHub Bot commented on KAFKA-6773:
---------------------------------------

hachikuji opened a new pull request #4851: KAFKA-6773; Allow offset 
commit/fetch/describe with empty groupId
URL: https://github.com/apache/kafka/pull/4851
 
 
   We had a regression in #4788 which caused the offset commit/fetch/describe 
APIs to fail if the groupId was empty. This should be allowed for backwards 
compatibility. I've added a test case to ensure that we do not miss this again 
in the future.
   
   ### Committer Checklist (excluded from commit message)
   - [ ] Verify design and implementation 
   - [ ] Verify test coverage and CI build status
   - [ ] Verify documentation (including upgrade notes)
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


> 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
>             Fix For: 1.2.0, 1.1.1
>
>
> 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)

Reply via email to