From d2c978c98e87bd38b525cca4368f8818d86c27fa Mon Sep 17 00:00:00 2001 From: "Matthias J. Sax" Date: Wed, 26 Aug 2020 10:31:16 -0700 Subject: [PATCH] MINOR: fix JavaDoc (#9217) Reviewer: John Roesler --- .../kafka/streams/errors/StreamsNotStartedException.java | 5 +++-- .../apache/kafka/streams/processor/api/ProcessorContext.java | 3 +-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/streams/src/main/java/org/apache/kafka/streams/errors/StreamsNotStartedException.java b/streams/src/main/java/org/apache/kafka/streams/errors/StreamsNotStartedException.java index 524e5f67654..562be0ebde8 100644 --- a/streams/src/main/java/org/apache/kafka/streams/errors/StreamsNotStartedException.java +++ b/streams/src/main/java/org/apache/kafka/streams/errors/StreamsNotStartedException.java @@ -17,11 +17,12 @@ package org.apache.kafka.streams.errors; import org.apache.kafka.streams.KafkaStreams; +import org.apache.kafka.streams.KafkaStreams.State; /** - * Indicates that Kafka Streams is in state {@link KafkaStreams.State#CREATED CREATED} and thus state stores cannot be queries yet. + * Indicates that Kafka Streams is in state {@link State CREATED} and thus state stores cannot be queries yet. * To query state stores, it's required to first start Kafka Streams via {@link KafkaStreams#start()}. - * You can retry to query the state after the state transitioned to {@link KafkaStreams.State#RUNNING RUNNING}. + * You can retry to query the state after the state transitioned to {@link State RUNNING}. */ public class StreamsNotStartedException extends InvalidStateStoreException { diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java b/streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java index 4b98e6a44d2..2ef3b29ec99 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java @@ -21,7 +21,6 @@ import org.apache.kafka.common.serialization.Serde; import org.apache.kafka.streams.StreamsMetrics; import org.apache.kafka.streams.errors.StreamsException; import org.apache.kafka.streams.processor.Cancellable; -import org.apache.kafka.streams.processor.Processor; import org.apache.kafka.streams.processor.PunctuationType; import org.apache.kafka.streams.processor.Punctuator; import org.apache.kafka.streams.processor.StateRestoreCallback; @@ -106,7 +105,7 @@ public interface ProcessorContext { /** * Schedules a periodic operation for processors. A processor may call this method during - * {@link Processor#init(org.apache.kafka.streams.processor.ProcessorContext) initialization} or + * {@link Processor#init(ProcessorContext) initialization} or * {@link Processor#process(Object, Object) processing} to * schedule a periodic callback — called a punctuation — to {@link Punctuator#punctuate(long)}. * The type parameter controls what notion of time is used for punctuation: