覆盖 Kafka Connect 中的属性

Question

我需要使用 Mongo Connect 覆盖一些属性。我在

connect-distributed.properties

中添加了行

connector.client.config.override.policy=ALL

就像本教程中一样 https://debezium.io/documentation/faq/#how_to_enlarge_the_maximum_size_of_the_message_delivered_to_kafka

但是在配置中添加选项

producer.override.max.request.size

之后，我发现了

The 'None' policy does not allow 'max.request.size' to be overridden in the connector configuration.

可能是什么错误？

Answer 1

在

connect-distributed.properties

中，您需要将

connector.client.config.override.policy

配置为

All

（小写L）

参考：https://docs.confluence.io/platform/current/connect/references/allconfigs.html#override-the-worker-configuration