From c5e984aee35b65c99c3152a2340850a4c73b14d2 Mon Sep 17 00:00:00 2001 From: "Matthias J. Sax" Date: Tue, 16 Jan 2024 17:33:48 -0800 Subject: [PATCH] MINOR: code cleanup Follow up to #15199 Remove unnecessary import and add new member variable. --- .../main/java/org/apache/kafka/streams/StreamsConfig.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) 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 f8f84e9e9c28..781b63bdef90 100644 --- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java +++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java @@ -71,7 +71,6 @@ import static org.apache.kafka.common.config.ConfigDef.Range.between; import static org.apache.kafka.common.config.ConfigDef.ValidString.in; import static org.apache.kafka.common.config.ConfigDef.parseType; -import static org.apache.kafka.streams.internals.UpgradeFromValues.UPGRADE_FROM_35; /** * Configuration for a {@link KafkaStreams} instance. @@ -408,6 +407,12 @@ public class StreamsConfig extends AbstractConfig { @SuppressWarnings("WeakerAccess") public static final String UPGRADE_FROM_34 = UpgradeFromValues.UPGRADE_FROM_34.toString(); + /** + * Config value for parameter {@link #UPGRADE_FROM_CONFIG "upgrade.from"} for upgrading an application from version {@code 3.5.x}. + */ + @SuppressWarnings("WeakerAccess") + public static final String UPGRADE_FROM_35 = UpgradeFromValues.UPGRADE_FROM_35.toString(); + /** * Config value for parameter {@link #PROCESSING_GUARANTEE_CONFIG "processing.guarantee"} for at-least-once processing guarantees. */