Merge pull request #958 from Aiven-Open/jjaakola-aiven-remove-test-co…

…mmitted-flaky-test

test: remove flaky TestCommitted test

tests/integration/kafka/test_consumer.py

@@ -4,7 +4,7 @@
 """
 from __future__ import annotations
 
-from aiokafka.errors import IllegalStateError, KafkaTimeoutError, UnknownTopicOrPartitionError
+from aiokafka.errors import IllegalStateError, UnknownTopicOrPartitionError
 from confluent_kafka import OFFSET_BEGINNING, OFFSET_END, TopicPartition
 from confluent_kafka.admin import NewTopic
 from confluent_kafka.error import KafkaError
@@ -180,12 +180,6 @@ def test_commit_raises_for_unknown_partition(
             consumer.commit(offsets=[TopicPartition(new_topic.topic, partition=99, offset=0)])
 
 
-class TestCommitted:
-    def test_committed_raises_on_timeout(self, consumer: KafkaConsumer) -> None:
-        with pytest.raises(KafkaTimeoutError):
-            consumer.committed([], timeout=0.00001)
-
-
 class TestSubscribe:
     def _poll_until_no_message(self, consumer: KafkaConsumer) -> None:
         """Polls until there is no message returned.