kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch trunk updated: Minor: fix javadocs of StreamsConfig and ValueTransformerWithKey (#5157)
Date Sat, 30 Jun 2018 21:27:42 GMT
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 5732098  Minor: fix javadocs of StreamsConfig and ValueTransformerWithKey (#5157)
5732098 is described below

commit 57320981bb98086a0b9f836a29df248b1c0378c3
Author: Chia-Ping Tsai <chia7712@gmail.com>
AuthorDate: Sun Jul 1 05:27:30 2018 +0800

    Minor: fix javadocs of StreamsConfig and ValueTransformerWithKey (#5157)
    
    Reviewer: Matthias J. Sax <matthias@confluent.io>
---
 streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java   | 6 +++---
 .../org/apache/kafka/streams/kstream/ValueTransformerWithKey.java   | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
index cd9be33..eee5bc6 100644
--- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
+++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
@@ -927,7 +927,7 @@ public class StreamsConfig extends AbstractConfig {
      * Get the configs to the {@link KafkaConsumer main consumer}.
      * Properties using the prefix {@link #MAIN_CONSUMER_PREFIX} will be used in favor over
      * the properties prefixed with {@link #CONSUMER_PREFIX} and the non-prefixed versions
-     * (read the override precedence ordering in {@link #MAIN_CONSUMER_PREFIX)
+     * (read the override precedence ordering in {@link #MAIN_CONSUMER_PREFIX}
      * except in the case of {@link ConsumerConfig#BOOTSTRAP_SERVERS_CONFIG} where we always
use the non-prefixed
      * version as we only support reading/writing from/to the same Kafka Cluster.
      * If not specified by {@link #MAIN_CONSUMER_PREFIX}, main consumer will share the general
consumer configs
@@ -995,7 +995,7 @@ public class StreamsConfig extends AbstractConfig {
      * Get the configs for the {@link KafkaConsumer restore-consumer}.
      * Properties using the prefix {@link #RESTORE_CONSUMER_PREFIX} will be used in favor
over
      * the properties prefixed with {@link #CONSUMER_PREFIX} and the non-prefixed versions
-     * (read the override precedence ordering in {@link #RESTORE_CONSUMER_PREFIX)
+     * (read the override precedence ordering in {@link #RESTORE_CONSUMER_PREFIX}
      * except in the case of {@link ConsumerConfig#BOOTSTRAP_SERVERS_CONFIG} where we always
use the non-prefixed
      * version as we only support reading/writing from/to the same Kafka Cluster.
      * If not specified by {@link #RESTORE_CONSUMER_PREFIX}, restore consumer will share
the general consumer configs
@@ -1027,7 +1027,7 @@ public class StreamsConfig extends AbstractConfig {
      * Get the configs for the {@link KafkaConsumer global consumer}.
      * Properties using the prefix {@link #GLOBAL_CONSUMER_PREFIX} will be used in favor
over
      * the properties prefixed with {@link #CONSUMER_PREFIX} and the non-prefixed versions
-     * (read the override precedence ordering in {@link #GLOBAL_CONSUMER_PREFIX)
+     * (read the override precedence ordering in {@link #GLOBAL_CONSUMER_PREFIX}
      * except in the case of {@link ConsumerConfig#BOOTSTRAP_SERVERS_CONFIG} where we always
use the non-prefixed
      * version as we only support reading/writing from/to the same Kafka Cluster.
      * If not specified by {@link #GLOBAL_CONSUMER_PREFIX}, global consumer will share the
general consumer configs
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
index 7f399b5..20c8692 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
@@ -35,7 +35,7 @@ import org.apache.kafka.streams.processor.To;
  * Note that the key is read-only and should not be modified, as this can lead to corrupt
partitioning.
  * If {@code ValueTransformerWithKey} is applied to a {@link KeyValue} pair record the record's
key is preserved.
  * <p>
- * Use {@link ValueTransformerWithKeySupplier} to provide new instances of {@code {@link
ValueTransformerWithKey} to
+ * Use {@link ValueTransformerWithKeySupplier} to provide new instances of {@link ValueTransformerWithKey}
to
  * Kafka Stream's runtime.
  * <p>
  * If a record's key and value should be modified {@link Transformer} can be used.


Mime
View raw message