更新Kafka连接器的生产者配置

Question

我在ubuntu服务器上安装了Kafka，其debezium连接器与此非常相似。我正在尝试用以下更新生产者配置

max.in.flight.requests.per.connection=1
enable.idempotence=true
acks=all

为此，我更新了/etc/kafka/config/producer.properties文件。但当我检查连接日志时，我看到Producer配置如下：

ProducerConfig values:
acks = 1
enable.idempotence = false
max.in.flight.requests.per.connection = 5
....
....

带有消息Idempotence will be disabled because acks is set to 1, not set to 'all'.

所以我想知道在哪里可以更新这个配置？

Answer 1

没有任何东西实际使用producer.properties

要编辑Kafka Connect属性，如Debezium，请使用带有producer.override.的Debezium配置本身，或仅带有producer.前缀的connect-distributed.properties。

https://kafka.apache.org/documentation/#connect_running