image: 'apache/kafka:4.0.1' will got logs about Received request for api with key 2 (ListOffsets) and unsupported version 0
after set api version None, may be not immediately, but after some minutes.
consumer = KafkaConsumer(
topic,
bootstrap_servers=kafka_bootstrap_servers,
auto_offset_reset="earliest",
group_id=group_id,
api_version=None,
enable_auto_commit=False,
)
set (4,0,0) still exists,
set (3,0) okay now,
almost decided to use confluent-kafka instead.
version
kafka-python~=2.2.15