2024-04-27 00:11:56 发布
网友
kafka python包含多个用于创建/删除主题的模块,并在执行此操作时传递多个配置
是否有方法向以下方法添加其他配置-
NewTopic(name=topicname, num_partitions=1, replication_factor=1)
是的,可以使用kafka python创建压缩主题
^{}构造函数接受一个topic_configs参数来指定主题配置
topic_configs
例如:
from kafka import KafkaAdminClient from kafka.admin import NewTopic admin = KafkaAdminClient(bootstrap_servers=['localhost:9092']) topic = NewTopic('bar', 1, 1, topic_configs={'cleanup.policy': 'compact'}) response = admin.create_topics([topic]) print(response)
是的,可以使用kafka python创建压缩主题
^{} 构造函数接受一个
topic_configs
参数来指定主题配置例如:
相关问题 更多 >
编程相关推荐