This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new ca834d11746 MINOR: remove incorrect deprecated annotations from 
internal Streams classes (#19195)
ca834d11746 is described below

commit ca834d11746c97b16f0e6b0c288e2398335d21db
Author: Alieh Saeedi <[email protected]>
AuthorDate: Thu Mar 13 01:49:00 2025 +0100

    MINOR: remove incorrect deprecated annotations from internal Streams 
classes (#19195)
    
    Reviewers: Matthias J. Sax <[email protected]>
---
 .../kafka/streams/processor/internals/AbstractReadOnlyDecorator.java   | 3 ---
 .../org/apache/kafka/streams/state/internals/InMemoryWindowStore.java  | 3 ---
 2 files changed, 6 deletions(-)

diff --git 
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java
 
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java
index 12326ef5721..c8b683aa96c 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java
@@ -206,7 +206,6 @@ abstract class AbstractReadOnlyDecorator<T extends 
StateStore, K, V> extends Wra
         }
 
         @Override
-        @Deprecated
         public WindowStoreIterator<V> fetch(final K key,
                                             final long timeFrom,
                                             final long timeTo) {
@@ -221,7 +220,6 @@ abstract class AbstractReadOnlyDecorator<T extends 
StateStore, K, V> extends Wra
         }
 
         @Override
-        @Deprecated
         public KeyValueIterator<Windowed<K>, V> fetch(final K keyFrom,
                                                       final K keyTo,
                                                       final long timeFrom,
@@ -248,7 +246,6 @@ abstract class AbstractReadOnlyDecorator<T extends 
StateStore, K, V> extends Wra
         }
 
         @Override
-        @Deprecated
         public KeyValueIterator<Windowed<K>, V> fetchAll(final long timeFrom,
                                                          final long timeTo) {
             return wrapped().fetchAll(timeFrom, timeTo);
diff --git 
a/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java
 
b/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java
index 4b224926f50..d3d5ba4a20d 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java
@@ -196,7 +196,6 @@ public class InMemoryWindowStore implements 
WindowStore<Bytes, byte[]> {
         }
     }
 
-    @Deprecated
     @Override
     public WindowStoreIterator<byte[]> fetch(final Bytes key, final long 
timeFrom, final long timeTo) {
         return fetch(key, timeFrom, timeTo, true);
@@ -236,7 +235,6 @@ public class InMemoryWindowStore implements 
WindowStore<Bytes, byte[]> {
         }
     }
 
-    @Deprecated
     @Override
     public KeyValueIterator<Windowed<Bytes>, byte[]> fetch(final Bytes keyFrom,
                                                            final Bytes keyTo,
@@ -294,7 +292,6 @@ public class InMemoryWindowStore implements 
WindowStore<Bytes, byte[]> {
         }
     }
 
-    @Deprecated
     @Override
     public KeyValueIterator<Windowed<Bytes>, byte[]> fetchAll(final long 
timeFrom, final long timeTo) {
         return fetchAll(timeFrom, timeTo, true);

Reply via email to