Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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. 

...