diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachProcessor.java b/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachProcessor.java index bbf614a08ec2..1555fbd7d05e 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachProcessor.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachProcessor.java @@ -19,7 +19,9 @@ import org.apache.kafka.streams.processor.api.Processor; import org.apache.kafka.streams.processor.api.Record; -// deprecated since 4.0. +/** + * @deprecated since 4.0 and should not be used any longer. + */ @Deprecated public class ForeachProcessor implements Processor {