root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

KAFKA-19181: removed assertions in test_share_multiple_partitions as a result of change in assignor algorithm (#19541) 

The system test `ShareConsumerTest.test_share_multiple_partitions`
started failing because of the recent change in the SimpleAssignor
algorithm. The tests assumed that if a share group is subscribed to a
topic, then every share consumers part of the group will be assigned all
partitions of the topic. But that does not happen now, and partitions
are split between the share consumers in certain cases, in which some
partitions are only assigned to a subset of share consumers. This change
removes that assumption

Reviewers: PoAn Yang <payang@apache.org>, Andrew Schofield <aschofield@confluent.io>
This commit is contained in:
Chirag Wadhwa 2025-04-23 14:16:07 +05:30 committed by GitHub
parent 71d08780d1
commit b088ba7999
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/kafkatest/tests/client/share_consumer_test.py
View File

@ -168,11 +168,6 @@ class ShareConsumerTest(VerifiableShareConsumerTest):
for event_handler in consumer.event_handlers.values():
assert event_handler.total_consumed > 0
assert event_handler.total_acknowledged_successfully > 0
for topic_partition in self.get_topic_partitions(self.TOPIC2):
assert topic_partition in event_handler.consumed_per_partition
assert event_handler.consumed_per_partition[topic_partition] > 0
assert topic_partition in event_handler.acknowledged_per_partition
assert event_handler.acknowledged_per_partition[topic_partition] > 0
producer.stop()
consumer.stop_all()