(kafka) branch trunk updated: MINOR: Remove EnrichedSourceConnectorConfig (#23003)

[chia7712]

This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new dddb62455b8 MINOR: Remove EnrichedSourceConnectorConfig (#23003)
dddb62455b8 is described below

commit dddb62455b8094c431286017f605ebf2daca7415
Author: YANG-SYUAN CHOU <dino289...@gmail.com>
AuthorDate: Sat Aug 1 23:08:07 2026 +0800

    MINOR: Remove EnrichedSourceConnectorConfig (#23003)
    
    `EnrichedSourceConnectorConfig` only delegates to `ConnectorConfig` and
    no longer provides additional behavior.
    
    This PR remove the redundant subclass and use `ConnectorConfig`
    directly.   This is an internal cleanup with no behavioral change.
    
    This PR follows up on [this review
    
    
discussion](https://github.com/apache/kafka/pull/13259#discussion_r3688791218).
    
    Reviewers: Ken Huang <s7133...@gmail.com>, Chia-Ping Tsai
     <chia7...@gmail.com>
---
 .../apache/kafka/connect/runtime/SourceConnectorConfig.java   | 11 ++---------
 1 file changed, 2 insertions(+), 9 deletions(-)

diff --git 
a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java
 
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java
index e9913e81f4c..4b6650bb869 100644
--- 
a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java
+++ 
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java
@@ -113,16 +113,9 @@ public final class SourceConnectorConfig extends 
ConnectorConfig {
             + "has been overridden from the worker's). Only applicable in 
distributed mode; in standalone mode, setting this property will have no 
effect.";
     private static final String OFFSETS_TOPIC_DISPLAY = "Offsets topic";
 
-    private static class EnrichedSourceConnectorConfig extends ConnectorConfig 
{
-        EnrichedSourceConnectorConfig(Plugins plugins, ConfigDef configDef, 
Map<String, String> props) {
-            super(plugins, configDef, props);
-        }
-
-    }
-
     private final TransactionBoundary transactionBoundary;
     private final Long transactionBoundaryInterval;
-    private final EnrichedSourceConnectorConfig enrichedSourceConfig;
+    private final ConnectorConfig enrichedSourceConfig;
     private final String offsetsTopic;
 
     private static ConfigDef configDef(ConfigDef baseConfigDef) {
@@ -273,7 +266,7 @@ public final class SourceConnectorConfig extends 
ConnectorConfig {
             propsWithoutRegexForDefaultGroup.entrySet()
                     .removeIf(e -> 
e.getKey().equals(DEFAULT_TOPIC_CREATION_PREFIX + INCLUDE_REGEX_CONFIG)
                             || e.getKey().equals(DEFAULT_TOPIC_CREATION_PREFIX 
+ EXCLUDE_REGEX_CONFIG));
-            enrichedSourceConfig = new EnrichedSourceConnectorConfig(plugins,
+            enrichedSourceConfig = new ConnectorConfig(plugins,
                     enrich(defaultConfigDef, props, defaultGroup),
                     propsWithoutRegexForDefaultGroup);
         } else {