Питон. Kafka Raft подключается к контроллеру ⇐ Python

[Anonymous]

Я хочу подключиться к kraft-контроллеру через порт 9093 (не брокер). И я не могу подключить
пример кода:

Код: Выделить всё

#!/usr/bin/env python3

from confluent_kafka.admin import AdminClient
import json
import os

credentials = 'credentials/example.json'
with open(credentials, 'r') as json_file:
data = json.load(json_file)

conf = {
'bootstrap.servers': 'kafkacontroller1.example.com:9093',
'security.protocol': 'SASL_SSL',
'ssl.ca.location': os.path.abspath('./credentials/example/ca_cert'),
'ssl.certificate.location': os.path.abspath('./credentials/example/ca'),
'ssl.key.location': os.path.abspath('./credentials/example/ca_key'),
'ssl.key.password': data['SSLKeyPassword'],
'sasl.mechanism': 'PLAIN',
'sasl.username': data['username'],
'sasl.password': data['password'],
'enable.ssl.certificate.verification': 'false',
'debug': 'security,broker,protocol'
}

admin_client = AdminClient(conf)

try:
cluster_metadata = admin_client.list_topics(timeout=10)

controller_id = cluster_metadata.controller_id
print(f"Controller ID: {controller_id}")

brokers = cluster_metadata.brokers
print(f"Total brokers: {len(brokers)}")

print(f"Number of controllers: {1 if controller_id else 0}")

except Exception as e:
print(f"Error occurred: {e}")

Конечно, он не подключился.
Приведенный пример кода отлично работает с брокером, но вообще не работает с контроллером.
Итак, вопрос есть - стоит ли вообще пытаться подключиться к контроллеру? Если да, то как и что я там увижу?
Я бы ожидал получить от контроллера какое-то понятное состояние кластера, если это возможно.


Подробнее здесь: https://stackoverflow.com/questions/790 ... controller