重写Kafka Connect中的属性



我需要使用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

相关内容

  • 没有找到相关文章

最新更新