有没有办法使用 kafka-python 库创建日志压缩主题？

Question

kafka-python 包含 create/delete 主题的多个模块，并在这样做时传递多个配置。

有没有办法为以下方法添加额外的配置 -

NewTopic(name=topicname, num_partitions=1, replication_factor=1)

Answer 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)

有没有办法使用 kafka-python 库创建日志压缩主题？

Is there a way to create log compacted topic using kafka-python library?

python

apache-kafka

kafka-python