From 9980e12ce1be1eee086e31723a5e97f2ebd9ead1 Mon Sep 17 00:00:00 2001 From: Joao Pedro Fonseca Dantas <67479090+fonsdant@users.noreply.github.com> Date: Thu, 30 Jan 2025 16:02:07 -0300 Subject: [PATCH] MINOR: remove close from contextual processors javadoc Reviewers: Matthias J. Sax --- .../streams/processor/api/ContextualFixedKeyProcessor.java | 4 +--- .../kafka/streams/processor/api/ContextualProcessor.java | 3 +-- 2 files changed, 2 insertions(+), 5 deletions(-) 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