gpt4 book ai didi

python - 如何使用 kafka-python 以编程方式创建主题?

转载 作者:太空宇宙 更新时间:2023-11-03 21:04:29 27 4
gpt4 key购买 nike

我正在开始使用 Kafka,对 Python 还很陌生。我正在使用这个名为 kafka-python 的库与我的 Kafka 经纪人沟通。现在我需要从我的代码动态创建一个主题,从文档中我看到的是我可以调用 create_topics() 方法来执行此操作,但是我不确定,我将如何获得一个实例这个类。我无法从文档中理解这一点。

有人可以帮我解决这个问题吗?

最佳答案

您首先需要创建 KafkaAdminClient 的实例。以下内容应该可以帮助您:

from kafka.admin import KafkaAdminClient, NewTopic


admin_client = KafkaAdminClient(
bootstrap_servers="localhost:9092",
client_id='test'
)

topic_list = [NewTopic(name="example_topic", num_partitions=1, replication_factor=1)]
admin_client.create_topics(new_topics=topic_list, validate_only=False)
<小时/>

或者,您可以使用confluent_kafka客户端,它是 librdkafka 的轻量级包装器:

from confluent_kafka.admin import AdminClient, NewTopic


admin_client = AdminClient({"bootstrap_servers": "localhost:9092"})
topic_list = [NewTopic("example_topic", 1, 1)]
admin_client.create_topics(topic_list)

关于python - 如何使用 kafka-python 以编程方式创建主题?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55512586/

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