是否有任何可用于从python程序创建主题/删除主题的Python kafka管理客户端?我找到了一些python API,但都没有Admin API可用?

合流有python admin api吗?

最佳答案

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)

07-24 09:38
查看更多