python - 有没有办法使用 kafka-python 库创建日志压缩主题?
问题描述
kafka-python 包含多个模块来创建/删除主题,并在此过程中传递多个配置。
有没有办法为以下方法添加额外的配置 -
NewTopic(name=topicname, num_partitions=1, replication_factor=1)
解决方案
是的,可以使用 kafka-python 创建压缩主题。
构造NewTopic
函数接受一个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)
推荐阅读
- html - 无法将纯 HTML 类应用于 Blazor 组件
- google-cloud-firestore - Where to put ShareReplay(1) pipe
- node.js - How can I filter arrays in mongodb using mongoose?
- c# - Using C#, how can I pass an argument from one project to another
- sql - Multiple Insert Statement Postgres while Retaining Generated ID between Insert Statements
- jquery - Recaptha v2 徽章
- java - 使用“C++”的“Atom”ide中的这个“插入排序”代码正确地给出了输出,但在使用“java”的“Intellij Idea”中,相同的代码给出了超出范围的索引
- android - 哪个 Flutter 插件或功能可以利用外部 iOS/Android 显示器显示与主显示器不同的内容
- node.js - 在快速类型定义文件中找不到接口请求的导出
- angular - 角度嵌套对象