You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Konstantine Karantasis (JIRA)" <ji...@apache.org> on 2018/04/10 22:20:00 UTC

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

Konstantine Karantasis created KAFKA-6773:
---------------------------------------------

             Summary: 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
    Affects Versions: 1.2.0, 1.1.1
            Reporter: Konstantine Karantasis
            Assignee: Jason Gustafson
             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)