This is an automated email from the ASF dual-hosted git repository. rzo1 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/storm.git
commit 2439a2b69e3acd1cf908af2253cc82eebf835055 Author: Richard Zowalla <[email protected]> AuthorDate: Fri Aug 25 09:38:09 2023 +0200 STORM-3936 - Fix errors/warnings found while generating javadoc in storm-kafka-client --- .../src/main/java/org/apache/storm/kafka/bolt/KafkaBolt.java | 4 ++-- .../src/main/java/org/apache/storm/kafka/spout/KafkaTuple.java | 2 +- .../java/org/apache/storm/kafka/spout/subscription/TopicAssigner.java | 2 -- 3 files changed, 3 insertions(+), 5 deletions(-) diff --git a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/KafkaBolt.java b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/KafkaBolt.java index f3fc80805..498499965 100644 --- a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/KafkaBolt.java +++ b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/KafkaBolt.java @@ -66,11 +66,11 @@ public class KafkaBolt<K, V> extends BaseTickTupleAwareRichBolt { private PreparableCallback providedCallback; private Properties boltSpecifiedProperties = new Properties(); /** - * {@see KafkaBolt#setFireAndForget(boolean)} for more details on this. + * {@link KafkaBolt#setFireAndForget(boolean)} for more details on this. */ private boolean fireAndForget = false; /** - * {@see KafkaBolt#setAsync(boolean)} for more details on this. + * {@link KafkaBolt#setAsync(boolean)} for more details on this. */ private boolean async = true; diff --git a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaTuple.java b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaTuple.java index 02085f22b..2efb6a332 100644 --- a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaTuple.java +++ b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaTuple.java @@ -22,7 +22,7 @@ import org.apache.storm.tuple.Values; /** * A list of Values in a tuple that can be routed - * to a given stream. {@see org.apache.storm.kafka.spout.RecordTranslator#apply} + * to a given stream: {@link org.apache.storm.kafka.spout.RecordTranslator#apply}. */ public class KafkaTuple extends Values { private static final long serialVersionUID = 4803794470450587992L; diff --git a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/TopicAssigner.java b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/TopicAssigner.java index b8f931364..2101dbf44 100644 --- a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/TopicAssigner.java +++ b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/TopicAssigner.java @@ -31,8 +31,6 @@ public class TopicAssigner implements Serializable { /** * Assign partitions to the KafkaConsumer. - * @param <K> The consumer key type - * @param <V> The consumer value type * @param consumer The Kafka consumer to assign partitions to * @param newAssignment The partitions to assign. * @param listener The rebalance listener to call back on when the assignment changes
