From 7fff465df215e55af346445217570917a11a1d6d Mon Sep 17 00:00:00 2001 From: ABDELHALIM DIAB <_Abdelhalim.Diab.ext@pluxeegroup.com> Date: Tue, 16 Sep 2025 15:44:56 +0200 Subject: [PATCH] fix(plugin): fix regex router cleanup policy typo --- .../filepulse/fs/clean/RegexRouterCleanupPolicy.java | 8 ++++---- .../filepulse/fs/clean/RegexRouterCleanupPolicyTest.java | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/connect-file-pulse-plugin/src/main/java/io/streamthoughts/kafka/connect/filepulse/fs/clean/RegexRouterCleanupPolicy.java b/connect-file-pulse-plugin/src/main/java/io/streamthoughts/kafka/connect/filepulse/fs/clean/RegexRouterCleanupPolicy.java index 746f6db3d..779ef8b2c 100644 --- a/connect-file-pulse-plugin/src/main/java/io/streamthoughts/kafka/connect/filepulse/fs/clean/RegexRouterCleanupPolicy.java +++ b/connect-file-pulse-plugin/src/main/java/io/streamthoughts/kafka/connect/filepulse/fs/clean/RegexRouterCleanupPolicy.java @@ -28,13 +28,13 @@ public final class RegexRouterCleanupPolicy implements FileCleanupPolicy { public static final String SUCCESS_ROUTE_TOPIC_REGEX_CONFIG = CONFIG_PREFIX + "success.uri.regex"; private static final String SUCCESS_ROUTE_TOPIC_REGEX_DOC = - "Regular expression to use for matching objects in success."; + "Regular expression to use for matching objects in success."; public static final String SUCCESS_ROUTE_TOPIC_REPLACEMENT_CONFIG = CONFIG_PREFIX + "success.uri.replacement"; private static final String SUCCESS_ROUTE_TOPIC_REPLACEMENT_DOC = "Replacement string."; public static final String FAILURE_ROUTE_TOPIC_REGEX_CONFIG = CONFIG_PREFIX + "failure.uri.regex"; private static final String FAILURE_ROUTE_TOPIC_REGEX_DOC = - "Regular expression to use for matching objects in failure."; + "Regular expression to use for matching objects in failure."; public static final String FAILURE_ROUTE_TOPIC_REPLACEMENT_CONFIG = CONFIG_PREFIX + "failure.uri.replacement"; private static final String FAILURE_ROUTE_TOPIC_REPLACEMENT_DOC = "Replacement string."; @@ -57,8 +57,8 @@ public void configure(final Map configs) { successReplacement = simpleConfig.getString(SUCCESS_ROUTE_TOPIC_REPLACEMENT_CONFIG); successRegex = Pattern.compile(simpleConfig.getString(SUCCESS_ROUTE_TOPIC_REGEX_CONFIG)); - failureReplacement = simpleConfig.getString(SUCCESS_ROUTE_TOPIC_REPLACEMENT_CONFIG); - failureRegex = Pattern.compile(simpleConfig.getString(SUCCESS_ROUTE_TOPIC_REGEX_CONFIG)); + failureReplacement = simpleConfig.getString(FAILURE_ROUTE_TOPIC_REPLACEMENT_CONFIG); + failureRegex = Pattern.compile(simpleConfig.getString(FAILURE_ROUTE_TOPIC_REGEX_CONFIG)); } /** diff --git a/connect-file-pulse-plugin/src/test/java/io/streamthoughts/kafka/connect/filepulse/fs/clean/RegexRouterCleanupPolicyTest.java b/connect-file-pulse-plugin/src/test/java/io/streamthoughts/kafka/connect/filepulse/fs/clean/RegexRouterCleanupPolicyTest.java index f081636f6..4e93229b0 100644 --- a/connect-file-pulse-plugin/src/test/java/io/streamthoughts/kafka/connect/filepulse/fs/clean/RegexRouterCleanupPolicyTest.java +++ b/connect-file-pulse-plugin/src/test/java/io/streamthoughts/kafka/connect/filepulse/fs/clean/RegexRouterCleanupPolicyTest.java @@ -76,8 +76,8 @@ void should_rename_failure_file_given_cleanup_with_custom_config() { try (RegexRouterCleanupPolicy policy = new RegexRouterCleanupPolicy()) { policy.setStorage(new LocalFileStorage()); policy.configure(Map.of( - RegexRouterCleanupPolicy.SUCCESS_ROUTE_TOPIC_REGEX_CONFIG,"(.*).txt", - RegexRouterCleanupPolicy.SUCCESS_ROUTE_TOPIC_REPLACEMENT_CONFIG, "$1-DONE-FAILURE.txt" + RegexRouterCleanupPolicy.FAILURE_ROUTE_TOPIC_REGEX_CONFIG,"(.*).txt", + RegexRouterCleanupPolicy.FAILURE_ROUTE_TOPIC_REPLACEMENT_CONFIG, "$1-DONE-FAILURE.txt" )); URI targetURI = policy.routeOnFailure(source.metadata().uri());