...
It also proposes to add an option to use the target cluster default for the target topic configurations instead of the source cluster default. For example, if the user wants to use the target cluster default, the ConfigPropertyFilter
would be used to check if the configuration on the source topic has been dynamically set , then only gets replicated to the target topicand decide which cluster default should be used.
Proposed Changes
1) Add a new method updateTopicConfigsUsingIncrementalAlterConfigs() to MirrorSourceConnector.java
which takes a list topic configurations as a parameter and calls incrementalAlterConfigs()
to the target cluster.
...