File tree Expand file tree Collapse file tree 1 file changed +11
-11
lines changed Expand file tree Collapse file tree 1 file changed +11
-11
lines changed Original file line number Diff line number Diff line change @@ -835,17 +835,17 @@ def test_alter_consumer_group_offsets_api():
835
835
a .alter_consumer_group_offsets ([request_with_group_and_topic_partition_offset1 ,
836
836
same_name_request ])
837
837
838
- with pytest .raises (KafkaException ):
839
- fs = a .alter_consumer_group_offsets ([request_with_group_and_topic_partition_offset1 ])
840
- for f in fs .values ():
841
- f .result (timeout = 10 )
842
-
843
- fs = a .alter_consumer_group_offsets ([request_with_group_and_topic_partition_offset1 ],
844
- request_timeout = 0.5 )
845
- for f in concurrent .futures .as_completed (iter (fs .values ())):
846
- e = f .exception (timeout = 1 )
847
- assert isinstance (e , KafkaException )
848
- assert e .args [0 ].code () == KafkaError ._TIMED_OUT
838
+ # with pytest.raises(KafkaException):
839
+ # fs = a.alter_consumer_group_offsets([request_with_group_and_topic_partition_offset1])
840
+ # for f in fs.values():
841
+ # f.result(timeout=10)
842
+
843
+ # fs = a.alter_consumer_group_offsets([request_with_group_and_topic_partition_offset1],
844
+ # request_timeout=0.5)
845
+ # for f in concurrent.futures.as_completed(iter(fs.values())):
846
+ # e = f.exception(timeout=1)
847
+ # assert isinstance(e, KafkaException)
848
+ # assert e.args[0].code() == KafkaError._TIMED_OUT
849
849
850
850
with pytest .raises (ValueError ):
851
851
a .alter_consumer_group_offsets ([request_with_group_and_topic_partition_offset1 ],
You can’t perform that action at this time.
0 commit comments