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 <[email protected]> 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 <[email protected]>, TengYao Chi <[email protected]> --- 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(
