首页
学习
活动
专区
工具
TVP
发布
社区首页 >问答首页 >如何使用Python-kafka管理客户端在Kafka中创建topic?

如何使用Python-kafka管理客户端在Kafka中创建topic?
EN

Stack Overflow用户
提问于 2018-05-01 08:51:37
回答 2查看 4.8K关注 0票数 5

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

confluent有python管理api吗?

EN

回答 2

Stack Overflow用户

发布于 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)
票数 5
EN

Stack Overflow用户

发布于 2018-08-17 07:05:44

Confluent Python Kafka Client确实有管理员支持。

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

票数 -3
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/50110075

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档