This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch 3.6
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.6 by this push:
new e53d1ee4318 MINOR: code cleanup (#15208)
e53d1ee4318 is described below
commit e53d1ee43186d0505dc39a56465ecca4a768cf4a
Author: Matthias J. Sax <matth...@confluent.io>
AuthorDate: Wed Jan 17 23:59:09 2024 -0800
MINOR: code cleanup (#15208)
Follow up to #15199
Remove unnecessary import and add new member variable.
Reviewers: Walker Carlson <wcarl...@confluent.io>
---
streams/src/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 59b7856b29d..1cd80b2093d 100644
--- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
+++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
@@ -70,7 +70,6 @@ import static
org.apache.kafka.common.config.ConfigDef.Range.atLeast;
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.
*/
