diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/api/ContextualFixedKeyProcessor.java b/streams/src/main/java/org/apache/kafka/streams/processor/api/ContextualFixedKeyProcessor.java index 02f0ae2af1d73..7a10675ee59b7 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/api/ContextualFixedKeyProcessor.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/api/ContextualFixedKeyProcessor.java @@ -17,9 +17,7 @@ package org.apache.kafka.streams.processor.api; /** - * An abstract implementation of {@link FixedKeyProcessor} that manages the - * {@link FixedKeyProcessorContext} instance and provides default no-op - * implementation of {@link #close()}. + * An abstract implementation of {@link FixedKeyProcessor} that manages the {@link FixedKeyProcessorContext} instance. * * @param the type of input keys * @param the type of input values diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/api/ContextualProcessor.java b/streams/src/main/java/org/apache/kafka/streams/processor/api/ContextualProcessor.java index 96cc2784189b7..b3b420fd52f39 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/api/ContextualProcessor.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/api/ContextualProcessor.java @@ -17,8 +17,7 @@ package org.apache.kafka.streams.processor.api; /** - * An abstract implementation of {@link Processor} that manages the {@link ProcessorContext} instance and provides default no-op - * implementation of {@link #close()}. + * An abstract implementation of {@link Processor} that manages the {@link ProcessorContext} instance. * * @param the type of input keys * @param the type of input values