1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
Fix tests for Py3.11
Upstream-PR: https://github.com/dpkp/kafka-python/pull/2358
diff --git a/test/test_assignors.py b/test/test_assignors.py
index 67e91e131..a1214d8fa 100644
--- a/test/test_assignors.py
+++ b/test/test_assignors.py
@@ -661,7 +661,7 @@ def test_reassignment_with_random_subscriptions_and_changes(mocker, execution_nu
subscriptions = defaultdict(set)
for i in range(n_consumers):
- topics_sample = sample(all_topics, randint(1, len(all_topics) - 1))
+ topics_sample = sample(sorted(all_topics), randint(1, len(all_topics) - 1))
subscriptions['C{}'.format(i)].update(topics_sample)
member_metadata = make_member_metadata(subscriptions)
@@ -671,7 +671,7 @@ def test_reassignment_with_random_subscriptions_and_changes(mocker, execution_nu
subscriptions = defaultdict(set)
for i in range(n_consumers):
- topics_sample = sample(all_topics, randint(1, len(all_topics) - 1))
+ topics_sample = sample(sorted(all_topics), randint(1, len(all_topics) - 1))
subscriptions['C{}'.format(i)].update(topics_sample)
member_metadata = {}
|
