OmniaGM commented on code in PR #15999: URL: https://github.com/apache/kafka/pull/15999#discussion_r1639978395
########## connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConfig.java: ########## @@ -166,6 +169,34 @@ Duration consumerPollTimeout() { return Duration.ofMillis(getLong(CONSUMER_POLL_TIMEOUT_MILLIS)); } + public List<ConfigValue> validate() { + Boolean emitCheckpointsValue = this.getBoolean(EMIT_CHECKPOINTS_ENABLED); + Boolean syncGroupOffsetsValue = this.getBoolean(SYNC_GROUP_OFFSETS_ENABLED); + + List<ConfigValue> invalidConfigs = new ArrayList<>(); + if (!emitCheckpointsValue && !syncGroupOffsetsValue) { + ConfigValue syncGroupOffsets = new ConfigValue(SYNC_GROUP_OFFSETS_ENABLED); + ConfigValue emitCheckpoints = new ConfigValue(EMIT_CHECKPOINTS_ENABLED); + + String errorMessage = "MirrorCheckpointConnector can't run without both" + SYNC_GROUP_OFFSETS_ENABLED + ", " + Review Comment: I couldn't find a way to report warning on configs that doesn't make sense. Technically we can run the checkpoint connector without these features and if user later enabled these the connector would be fine. The down side is users might not notice that this connector is actually sitting idle. I can convert this method to just return boolean and log some warnings instead of failing the connector -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org