#apache-kafka #apache-kafka-connect
Вопрос:
Мне нужно переопределить некоторые свойства с помощью Mongo Connect. Я добавил строку в connect-distributed.properties с connector.client.config.override.policy=ВСЕ как в этом учебнике 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.
в чем может быть ошибка?
Комментарии:
1. Вы перезапустили кластер Connect? Файлы свойств читаются только при запуске
2. ДА. Я использую платформу от Confluent. Я изменил файл, перезапустил сервер, но поймал исключение
3. Если вы правильно установили значение, то ошибка не должна указывать на то, что вы используете
'None' policy
Ответ №1:
В connect-distributed.properties , вам нужно настроить connector.client.config.override.policy , чтобы All .