KAFKA-12796: Removal of deprecated classes under streams-scala (#10710)

Removes previously deprecated methods in older KIPs Reviewers: Bruno Cadonna <cadonna@apache.org>
apache · May 27, 2021 · a02b19c · a02b19c
1 parent 56d9482
commit a02b19c
Show file tree

Hide file tree

Showing 5 changed files with 1 addition and 311 deletions.
diff --git a/gradle/spotbugs-exclude.xml b/gradle/spotbugs-exclude.xml
@@ -421,12 +421,6 @@ For a detailed description of spotbugs bug categories, see https://spotbugs.read
         <Bug pattern="NN_NAKED_NOTIFY"/>
     </Match>
 
-    <Match>
-        <Package name="org.apache.kafka.streams.scala"/>
-        <Source name="FunctionConversions.scala"/>
-        <Bug pattern="EQ_UNUSUAL"/>
-    </Match>
-
     <Match>
         <Package name="org.apache.kafka.streams.scala"/>
         <Source name="FunctionsCompatConversions.scala"/>

diff --git a/...ams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionConversions.scala b/...ams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionConversions.scala
diff --git a/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KTable.scala b/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KTable.scala
@@ -304,7 +304,7 @@ class KTable[K, V](val inner: KTableJ[K, V]) {
     new KStream(inner.toStream[KR](mapper.asKeyValueMapper, named))
 
   /**
-   * Suppress some updates from this changelog stream, determined by the supplied [[Suppressed]] configuration.
+   * Suppress some updates from this changelog stream, determined by the supplied [[org.apache.kafka.streams.kstream.Suppressed]] configuration.
    *
    * This controls what updates downstream table and stream operations will receive.
    *

diff --git a/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Suppressed.scala b/streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Suppressed.scala
diff --git a/.../streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/SuppressedTest.scala b/.../streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/SuppressedTest.scala