[
https://issues.apache.org/jira/browse/KAFKA-3728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15291108#comment-15291108
]
Rajini Sivaram commented on KAFKA-3728:
---------------------------------------
EndToEndAuthorizationTest has a misconfigured __consumer_offsets topic, created
with one replica when the broker is configured with MinInsyncReplicas set to 3.
The test passes because it performs assign() rather than subscribe() and does
not commit any offsets (basically doesn't use the offsets topic). Changing
assign() to subscribe() causes the test to use the offsets topic, resulting in
the error above.
> inconsistent behavior of Consumer.poll() when assigned vs subscribed
> --------------------------------------------------------------------
>
> Key: KAFKA-3728
> URL: https://issues.apache.org/jira/browse/KAFKA-3728
> Project: Kafka
> Issue Type: Bug
> Reporter: Edoardo Comar
>
> A consumer that is manually assigned a topic-partition is able to consume
> messages that a consumer that subscribes to the topic can not.
> To reproduce : take the test
> EndToEndAuthorizationTest.testProduceConsume
> (eg the SaslSslEndToEndAuthorizationTest implementation)
>
> it passes ( = messages are consumed)
> if the consumer is assigned the single topic-partition
> consumers.head.assign(List(tp).asJava)
> but fails
> if the consumer subscribes to the topic - changing the line to :
> consumers.head.subscribe(List(topic).asJava)
> The failure when subscribed shows this error about synchronization:
> org.apache.kafka.common.KafkaException: Unexpected error from SyncGroup:
> Messages are rejected since there are fewer in-sync replicas than required.
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:455)
> The test passes in both cases (subscribe and assign) with the setting
> this.serverConfig.setProperty(KafkaConfig.MinInSyncReplicasProp, "1")
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
