覆盖 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。

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