Skip to content

MINOR: update java doc for deprecated methods (#10722) #8

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
sakibguy merged 1 commit into from
May 24, 2021
Merged

MINOR: update java doc for deprecated methods (#10722) #8

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 2 additions & 6 deletions streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,8 @@

/**
* 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
*/
Expand Down Expand Up @@ -61,7 +62,6 @@ protected Produced(final Produced<K, V> produced) {
* @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,
Expand All @@ -80,7 +80,6 @@ public static <K, V> Produced<K, V> with(final Serde<K> keySerde,
* @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,
Expand All @@ -107,7 +106,6 @@ public static <K, V> Produced<K, V> as(final String processorName) {
* @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) {
Expand All @@ -120,7 +118,6 @@ public static <K, V> Produced<K, V> keySerde(final Serde<K> keySerde) {
* @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) {
Expand All @@ -135,7 +132,6 @@ public static <K, V> Produced<K, V> valueSerde(final Serde<V> valueSerde) {
* @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) {
Expand Down
2 changes: 1 addition & 1 deletion tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@
* 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>
Expand Down