KAFKA-12830: Remove Deprecated constructor in TimeWindowedDeserializer and TimeWindowedSerde (#16809)
Signed-off-by: PoAn Yang <payang@apache.org>
Reviewers: Josep Prat <josep.prat@aiven.io>
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java b/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java
index 0be750e..77825f2 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java
@@ -37,11 +37,6 @@
this(null, null);
}
- @Deprecated
- public TimeWindowedDeserializer(final Deserializer<T> inner) {
- this(inner, Long.MAX_VALUE);
- }
-
public TimeWindowedDeserializer(final Deserializer<T> inner, final Long windowSize) {
this.inner = inner;
this.windowSize = windowSize;
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/WindowedSerdes.java b/streams/src/main/java/org/apache/kafka/streams/kstream/WindowedSerdes.java
index 92971e0..4f3789b 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/WindowedSerdes.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/WindowedSerdes.java
@@ -29,11 +29,6 @@
super(new TimeWindowedSerializer<>(), new TimeWindowedDeserializer<>());
}
- @Deprecated
- public TimeWindowedSerde(final Serde<T> inner) {
- super(new TimeWindowedSerializer<>(inner.serializer()), new TimeWindowedDeserializer<>(inner.deserializer()));
- }
-
// This constructor can be used for serialize/deserialize a windowed topic
public TimeWindowedSerde(final Serde<T> inner, final long windowSize) {
super(new TimeWindowedSerializer<>(inner.serializer()), new TimeWindowedDeserializer<>(inner.deserializer(), windowSize));
@@ -59,14 +54,6 @@
}
/**
- * Construct a {@code TimeWindowedSerde} object for the specified inner class type.
- */
- @Deprecated
- public static <T> Serde<Windowed<T>> timeWindowedSerdeFrom(final Class<T> type) {
- return new TimeWindowedSerde<>(Serdes.serdeFrom(type));
- }
-
- /**
* Construct a {@code TimeWindowedSerde} object to deserialize changelog topic
* for the specified inner class type and window size.
*/
diff --git a/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala b/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
index d3cc612..ce03dde 100644
--- a/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
+++ b/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
@@ -39,9 +39,6 @@
implicit def JavaInteger: Serde[java.lang.Integer] = JSerdes.Integer()
implicit def UUID: Serde[util.UUID] = JSerdes.UUID()
- implicit def timeWindowedSerde[T](implicit tSerde: Serde[T]): WindowedSerdes.TimeWindowedSerde[T] =
- new WindowedSerdes.TimeWindowedSerde[T](tSerde)
-
implicit def sessionWindowedSerde[T](implicit tSerde: Serde[T]): WindowedSerdes.SessionWindowedSerde[T] =
new WindowedSerdes.SessionWindowedSerde[T](tSerde)
