gpt4 book ai didi

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

转载 作者:行者123 更新时间:2023-12-02 02:54:41 25 4
gpt4 key购买 nike

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

confluent 有 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)

关于apache-kafka - 如何使用 Python-kafka 管理客户端在 Kafka 中创建主题?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50110075/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com