File tree Expand file tree Collapse file tree 1 file changed +8
-6
lines changed Expand file tree Collapse file tree 1 file changed +8
-6
lines changed Original file line number Diff line number Diff line change 1717
1818from confluent_kafka import TopicPartition , IsolationLevel
1919from confluent_kafka .admin import ListOffsetsResultInfo , OffsetSpec
20+ from tests .common import TestUtils
2021
2122
2223def test_list_offsets (kafka_cluster ):
@@ -65,12 +66,13 @@ def test_list_offsets(kafka_cluster):
6566 assert isinstance (result , ListOffsetsResultInfo )
6667 assert (result .offset == 3 )
6768
68- requests = {topic_partition : OffsetSpec .max_timestamp ()}
69- futmap = admin_client .list_offsets (requests , ** kwargs )
70- for _ , fut in futmap .items ():
71- result = fut .result ()
72- assert isinstance (result , ListOffsetsResultInfo )
73- assert (result .offset == 1 )
69+ if TestUtils .use_kraft ():
70+ requests = {topic_partition : OffsetSpec .max_timestamp ()}
71+ futmap = admin_client .list_offsets (requests , ** kwargs )
72+ for _ , fut in futmap .items ():
73+ result = fut .result ()
74+ assert isinstance (result , ListOffsetsResultInfo )
75+ assert (result .offset == 1 )
7476
7577 requests = {topic_partition : OffsetSpec .for_timestamp (base_timestamp + 150 )}
7678 futmap = admin_client .list_offsets (requests , ** kwargs )
You can’t perform that action at this time.
0 commit comments