Есть ли способ создать сжатый журнал topi c с помощью библиотеки kafka- python?

Question

kafka- python содержит несколько модулей для создания / удаления topi c, а также передает несколько конфигураций при этом.

Есть ли способ добавить дополнительную конфигурацию в следующий метод -

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

Answer 1

Да, можно создать сжатую топи c с помощью kafka- python.

Конструктор NewTopic принимает аргумент topic_configs для указания топи c конфигурации.

Например:

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)