我需要使用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
后,I catth
The 'None' policy does not allow 'max.request.size' to be overridden in the connector configuration.
可能是什么错误?
在connect-distributed.properties
中,需要将connector.client.config.override.policy
配置为All
(小写L)
裁判:https://docs.confluent.io/platform/current/connect/references/allconfigs.html override-the-worker-configuration