Братцы, нужны советы мудрые. Решил я развернуть у себя на локальном

хосту отладочкую Кафку. Чтобы на ней тестировать своё приложение.

Взял я docker-compose.yaml от bitnami. Запустил его через docker-compose up — вроде запустилось.

Поставил я себе kafka-python==2.0.2 и попытался выполнить простенький питоний скрипт для проверки:
from kafka.admin import KafkaAdminClient, NewTopic

if __name__ == "__main__":
admin_client = KafkaAdminClient(
bootstrap_servers="localhost:9092",
client_id='test_admin'
)

print(admin_client)
print(admin_client.list_topics())

А мне тут же кидают ошибку NodeNotReadyError:
Traceback (most recent call last):
File "/home/felix/Projects/kafka_sandbox/kafka_sandbox/admin_topic.py", line 6, in <module>
admin_client = KafkaAdminClient(
File "/home/felix/Projects/kafka_sandbox/venv_py3.7/lib/python3.10/site-packages/kafka/admin/client.py", line 218, in __init__
self._refresh_controller_id()
File "/home/felix/Projects/kafka_sandbox/venv_py3.7/lib/python3.10/site-packages/kafka/admin/client.py", line 278, in _refresh_controller_id
controller_version = self._client.check_version(controller_id, timeout=(self.config['api_version_auto_timeout_ms'] / 1000))
File "/home/felix/Projects/kafka_sandbox/venv_py3.7/lib/python3.10/site-packages/kafka/client_async.py", line 909, in check_version
version = conn.check_version(timeout=remaining, strict=strict, topics=list(self.config['bootstrap_topics_filter']))
File "/home/felix/Projects/kafka_sandbox/venv_py3.7/lib/python3.10/site-packages/kafka/conn.py", line 1240, in check_version
raise Errors.NodeNotReadyError()
kafka.errors.NodeNotReadyError: NodeNotReadyError
Скажите, что я делаю не так?

А кафка поднялась?

Поднялась. kafka_1 | [2023-08-07 19:09:19,297] INFO Kafka version: 3.5.1 (org.apache.kafka.common.utils.AppInfoParser) kafka_1 | [2023-08-07 19:09:19,297] INFO Kafka commitId: 2c6fb6c54472e90a (org.apache.kafka.common.utils.AppInfoParser) kafka_1 | [2023-08-07 19:09:19,297] INFO Kafka startTimeMs: 1691435359296 (org.apache.kafka.common.utils.AppInfoParser) kafka_1 | [2023-08-07 19:09:19,297] INFO [KafkaRaftServer nodeId=0] Kafka Server started (kafka.server.KafkaRaftServer)

kcat -b 127.0.0.1:9092 -L работает?

~ kafkacat -b 127.0.0.1:9092 -L Metadata for all topics (from broker -1: 127.0.0.1:9092/bootstrap): 1 brokers: broker 0 at 800a652877b6:9092 (controller) 0 topics:

может апи версию поправить под нужную в подключении, что-то с ней не то?