有没有Python kafka管理客户端可以从python程序中创建/删除主题?我找到了一些python api,但它们都没有可用的Admin api?
confluent有python管理api吗?
发布于 2019-11-23 21:28:47
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)
发布于 2018-08-17 07:05:44
Confluent Python Kafka Client确实有管理员支持。
查看此example以了解如何使用它。
https://stackoverflow.com/questions/50110075
复制相似问题