producer config property 'acks' is not passed through

[blbradley]

Using Confluent 3.0.1 on Debian:

Traceback (most recent call last):
  File "./main.py", line 22, in <module>
    producer = Producer({'bootstrap.servers': bootstrap_servers, 'api.version.request': 'true', 'request.required.acks': -1})
cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "request.required.acks""}

All combinations with the above settings, short version acks, and '-1' has the same effect.

[edenhill]

acks (request.required.acks) is a topic-level configuration property so you will need to set it in the default.topic.conf sub-dict, like so:

conf = {'bootstrap.servers': broker,  'default.topic.config': {'acks': 'all'}}

[blbradley]

That worked. Thanks for the quick response.