Skip to content

Commit 275c944

Browse files
authored
KAFKA-19956: Fix flaky testRemoteAssignorRange (#21060)
This has been flaky, failing with "Topic does not exist" received in a response to a commit. This could happen given that the test had the default auto-commit enabled and was not explicitly closing the consumer (consumer.close triggered as part of the test infra tear down, which does close with timeout 0). Seems the topic could end up deleted before the auto-commit on close was processed. Disabling auto-commit, not needed for the test. Reviewers: Andrew Schofield <aschofield@confluent.io>
1 parent a9dff62 commit 275c944

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

core/src/test/scala/integration/kafka/api/PlaintextConsumerAssignorsTest.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -269,6 +269,7 @@ class PlaintextConsumerAssignorsTest extends AbstractConsumerTest {
269269
this.consumerConfig.setProperty(ConsumerConfig.GROUP_ID_CONFIG, "range-group")
270270
this.consumerConfig.setProperty(ConsumerConfig.GROUP_REMOTE_ASSIGNOR_CONFIG, "range")
271271
this.consumerConfig.setProperty(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, "30000")
272+
this.consumerConfig.setProperty(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false")
272273
val consumer = createConsumer()
273274

274275
// create two new topics, each having 2 partitions

0 commit comments

Comments
 (0)