From bc7e57242dbf481c13a6b3c1fc3798b7e4203c71 Mon Sep 17 00:00:00 2001 From: "Matthias J. Sax" Date: Fri, 2 May 2025 03:02:38 -0700 Subject: [PATCH] MINOR: remove @FunctionalInterface annotation (#19618) BatchingStateRestoreCallback's default implemeantion of restore() lead to waraning `FunctionalInterfaceMethodChanged`. Reviewers: Lucas Brutschy , PoAn Yang , Ken Huang , TengYao Chi --- .../kafka/streams/processor/BatchingStateRestoreCallback.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java b/streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java index 37801d1579d..c37d45a8016 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java @@ -28,11 +28,10 @@ import java.util.Collection; * It is expected that implementations of this class will not call the {@link StateRestoreCallback#restore(byte[], * byte[])} method. */ -@FunctionalInterface public interface BatchingStateRestoreCallback extends StateRestoreCallback { /** - * Called to restore a number of records. This method is called repeatedly until the {@link StateStore} is fulled + * Called to restore a number of records. This method is called repeatedly until the {@link StateStore} is fully * restored. * * @param records the records to restore.