This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch 3.8
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.8 by this push:
new 16e8f85466e KAFKA-17459 Stablize reassign_partitions_test.py (#17250)
16e8f85466e is described below
commit 16e8f85466e2974eb4b019aba123c0d4031bf865
Author: TengYao Chi <[email protected]>
AuthorDate: Tue Sep 24 17:36:36 2024 +0800
KAFKA-17459 Stablize reassign_partitions_test.py (#17250)
This test expects that each partition can receive the record, so using a
non-null key helps distribute the records more randomly.
Reviewers: Chia-Ping Tsai <[email protected]>
---
tests/kafkatest/tests/core/reassign_partitions_test.py | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/tests/kafkatest/tests/core/reassign_partitions_test.py
b/tests/kafkatest/tests/core/reassign_partitions_test.py
index acacd20241a..d7c459bfb9c 100644
--- a/tests/kafkatest/tests/core/reassign_partitions_test.py
+++ b/tests/kafkatest/tests/core/reassign_partitions_test.py
@@ -176,7 +176,11 @@ class ReassignPartitionsTest(ProduceConsumeValidateTest):
self.producer = VerifiableProducer(self.test_context,
self.num_producers,
self.kafka, self.topic,
throughput=self.producer_throughput,
- enable_idempotence=True)
+ enable_idempotence=True,
+ # This test aims to verify the
reassignment without failure, assuming that all partitions have data.
+ # To avoid the reassignment
behavior being affected by the `BuiltInPartitioner` (due to the key not being
set),
+ # we set a key for the message to
ensure both even data distribution across all partitions.
+ repeating_keys=100)
self.consumer = ConsoleConsumer(self.test_context, self.num_consumers,
self.kafka, self.topic,
consumer_timeout_ms=60000,
