...
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, so that it then only then can gets replicated to the target topic.
...
2) Extend ConfigPropertyFilter
class to have a method called shouldReplicateSourceDefault
which can be used to replicate only if the configuration source is not would always return true by default. User would be able to configure this method to return true only if the configuration has been dynamically changed.
3) Update MirrorSourceConnector.java
class to sync a configuration only if shouldReplicateSourceDefault
returns trueDEFAULT_CONFIG.
2) Add a new configuration setting to MirrorMaker:
...