(kafka) 02/02: MINOR: deprecate internal config for NamedTopologies (#21921)

[mj...@apache.org]

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

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

commit 4852527b5cc1a27c0ea1d4028a113719fd21adc1
Author: Matthias J. Sax <ma...@confluent.io>
AuthorDate: Wed Apr 1 09:50:16 2026 -0700

    MINOR: deprecate internal config for NamedTopologies (#21921)
    
    NamedTopologies got deprecated via KAFKA-17805. This PR deprecates the
    internal "topic prefix" config, which is used by NamedTopologies.
    
    Reviewers: Christo Lolov <lo...@amazon.com>, TengYao Chi
     <fr...@apache.org>
---
 streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java       | 1 +
 .../kafka/streams/processor/internals/InternalTopologyBuilder.java      | 2 ++
 .../apache/kafka/streams/processor/internals/ProcessorContextUtils.java | 1 +
 .../kafka/streams/state/internals/TimeOrderedCachingWindowStore.java    | 1 +
 4 files changed, 5 insertions(+)

diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
index d28818e47e3..2d860cd7905 100644
--- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
+++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
@@ -1362,6 +1362,7 @@ public class StreamsConfig extends AbstractConfig {
             + ".vector.enabled__";
 
         // Private API used to control the prefix of the auto created topics
+        @Deprecated
         public static final String TOPIC_PREFIX_ALTERNATIVE = "__internal.override.topic.prefix__";
 
         // Private API to enable processing threads (i.e. polling is decoupled from processing)
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
index 86f1ebbe7a6..efdbf7d5974 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
@@ -1122,6 +1122,7 @@ public class InternalTopologyBuilder {
         }
     }
 
+    @SuppressWarnings("deprecation")
     private void buildProcessorNode(final Map<String, ProcessorNode<?, ?, ?, ?>> processorMap,
                                     final Map<String, StateStore> stateStoreMap,
                                     final ProcessorNodeFactory<?, ?, ?, ?> factory,
@@ -1456,6 +1457,7 @@ public class InternalTopologyBuilder {
         return decorateTopic(topic);
     }
 
+    @SuppressWarnings("deprecation")
     private String decorateTopic(final String topic) {
         if (applicationId == null) {
             throw new TopologyException("there are internal topics and "
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java
index 0515f8718aa..aade59a4f7d 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java
@@ -52,6 +52,7 @@ public final class ProcessorContextUtils {
         return ProcessorStateManager.storeChangelogTopic(prefix, storeName, context.taskId().topologyName());
     }
 
+    @Deprecated
     public static String topicNamePrefix(final Map<String, Object> configs, final String applicationId) {
         if (configs == null) {
             return applicationId;
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java
index aea172ea9cc..4e0fd29f09d 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java
@@ -113,6 +113,7 @@ public class TimeOrderedCachingWindowStore
         return null;
     }
 
+    @SuppressWarnings("deprecation")
     @Override
     public void init(final StateStoreContext stateStoreContext, final StateStore root) {
         final String prefix = StreamsConfig.InternalConfig.getString(