如何使用Python-kafka管理客户端在Kafka中创建主题？

Question

是否有任何Python kafka管理客户端可用于从python程序创建主题/删除主题？我发现了一些 python api，但它们都没有可用的 Admin api？

Confluence 有 python admin api 吗？

Answer 1

from kafka.admin import KafkaAdminClient, NewTopic
admin_client = KafkaAdminClient(bootstrap_servers="localhost:9092", client_id='test')

topic_list = []
topic_list.append(NewTopic(name="example_topic", num_partitions=1, replication_factor=1))
admin_client.create_topics(new_topics=topic_list, validate_only=False)

Answer 2

Confluence Python Kafka 客户端确实有管理支持。

查看此示例以了解如何使用它。