Настройка свойств производителя Kafka на AvroProducer в python

Question

Мне интересно, как добавить свойства к AvroProducer в python.

Вот код, который я пробовал, вы можете увидеть что-то вроде того, что я хотел бы сделать, но добавив в acks = все результаты в этой ошибке

TypeError: init () получил неожиданный аргумент ключевого слова 'acks'

avroProducer = AvroProducer(
{'bootstrap.servers': 'localhost:9092', 'schema.registry.url': 'http://127.0.0.1:8081'},
default_value_schema=value_schema, acks = "all")


avroProducer.produce(topic='test-topic', value=value,value_schema=value_schema)

Answer 1

решение ниже

avroProducer = AvroProducer({
    'bootstrap.servers': 'localhost:9092',
    'schema.registry.url': 'http://127.0.0.1:8081',
    'default.topic.config': {'acks': 'all'}},
    default_value_schema=value_schema)