diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java index 2978f943f31..109879579a6 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java @@ -271,18 +271,35 @@ public class Joined implements NamedOperation(keySerde, leftValueSerde, rightValueSerde, name, gracePeriod); } + + /** + * @deprecated since 4.0 and should not be used any longer. + */ + @Deprecated public Duration gracePeriod() { return gracePeriod; } + /** + * @deprecated since 4.0 and should not be used any longer. + */ + @Deprecated public Serde keySerde() { return keySerde; } + /** + * @deprecated since 4.0 and should not be used any longer. + */ + @Deprecated public Serde valueSerde() { return leftValueSerde; } + /** + * @deprecated since 4.0 and should not be used any longer. + */ + @Deprecated public Serde otherValueSerde() { return rightValueSerde; } diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/JoinedInternal.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/JoinedInternal.java index e01adb5ae4f..b323250e6f1 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/JoinedInternal.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/JoinedInternal.java @@ -27,10 +27,12 @@ public class JoinedInternal extends Joined super(joined); } + @SuppressWarnings("deprecation") public Duration gracePeriod() { return gracePeriod; } + @SuppressWarnings("deprecation") public Serde keySerde() { return keySerde; }