This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new efb7cda MINOR: update java doc for deprecated methods (#10722)
efb7cda is described below
commit efb7cda1789b27867a69d3a0131b56123ada0bbe
Author: Luke Chen <[email protected]>
AuthorDate: Mon May 24 09:33:01 2021 +0800
MINOR: update java doc for deprecated methods (#10722)
Reviewers: Matthias J. Sax <[email protected]>
---
.../src/main/java/org/apache/kafka/streams/kstream/Produced.java | 8 ++------
.../src/main/java/org/apache/kafka/tools/VerifiableConsumer.java | 2 +-
2 files changed, 3 insertions(+), 7 deletions(-)
diff --git
a/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java
index 6c3ed8c..b14c846 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java
@@ -26,7 +26,8 @@ import java.util.Objects;
/**
* This class is used to provide the optional parameters when producing to new
topics
- * using {@link KStream#through(String, Produced)} or {@link
KStream#to(String, Produced)}.
+ * using {@link KStream#to(String, Produced)}.
+ *
* @param <K> key type
* @param <V> value type
*/
@@ -61,7 +62,6 @@ public class Produced<K, V> implements
NamedOperation<Produced<K, V>> {
* @param <K> key type
* @param <V> value type
* @return A new {@link Produced} instance configured with keySerde and
valueSerde
- * @see KStream#through(String, Produced)
* @see KStream#to(String, Produced)
*/
public static <K, V> Produced<K, V> with(final Serde<K> keySerde,
@@ -80,7 +80,6 @@ public class Produced<K, V> implements
NamedOperation<Produced<K, V>> {
* @param <K> key type
* @param <V> value type
* @return A new {@link Produced} instance configured with keySerde,
valueSerde, and partitioner
- * @see KStream#through(String, Produced)
* @see KStream#to(String, Produced)
*/
public static <K, V> Produced<K, V> with(final Serde<K> keySerde,
@@ -107,7 +106,6 @@ public class Produced<K, V> implements
NamedOperation<Produced<K, V>> {
* @param <K> key type
* @param <V> value type
* @return A new {@link Produced} instance configured with keySerde
- * @see KStream#through(String, Produced)
* @see KStream#to(String, Produced)
*/
public static <K, V> Produced<K, V> keySerde(final Serde<K> keySerde) {
@@ -120,7 +118,6 @@ public class Produced<K, V> implements
NamedOperation<Produced<K, V>> {
* @param <K> key type
* @param <V> value type
* @return A new {@link Produced} instance configured with valueSerde
- * @see KStream#through(String, Produced)
* @see KStream#to(String, Produced)
*/
public static <K, V> Produced<K, V> valueSerde(final Serde<V> valueSerde) {
@@ -135,7 +132,6 @@ public class Produced<K, V> implements
NamedOperation<Produced<K, V>> {
* @param <K> key type
* @param <V> value type
* @return A new {@link Produced} instance configured with partitioner
- * @see KStream#through(String, Produced)
* @see KStream#to(String, Produced)
*/
public static <K, V> Produced<K, V> streamPartitioner(final
StreamPartitioner<? super K, ? super V> partitioner) {
diff --git a/tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java
b/tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java
index 5be76f0..e930580 100644
--- a/tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java
+++ b/tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java
@@ -73,7 +73,7 @@ import static
net.sourceforge.argparse4j.impl.Arguments.storeTrue;
* See {@link
org.apache.kafka.tools.VerifiableConsumer.PartitionsRevoked}</li>
* <li>partitions_assigned: outputs the partitions assigned through {@link
ConsumerRebalanceListener#onPartitionsAssigned(Collection)}
* See {@link
org.apache.kafka.tools.VerifiableConsumer.PartitionsAssigned}.</li>
- * <li>records_consumed: contains a summary of records consumed in a single
call to {@link KafkaConsumer#poll(long)}.
+ * <li>records_consumed: contains a summary of records consumed in a single
call to {@link KafkaConsumer#poll(Duration)}.
* See {@link
org.apache.kafka.tools.VerifiableConsumer.RecordsConsumed}.</li>
* <li>record_data: contains the key, value, and offset of an individual
consumed record (only included if verbose
* output is enabled). See {@link
org.apache.kafka.tools.VerifiableConsumer.RecordData}.</li>
