Repository: kafka Updated Branches: refs/heads/trunk a02c8aaec -> 18dd1986b
MINOR: Fix some copy-pasted Javadoc in StreamsConfig.java This contribution is my original work and I license the work to the Kafka project under the project's open source license. cc guozhangwang miguno ymatsuda Author: Jeff Klukas <[email protected]> Reviewers: Michael G. Noll <[email protected]>, Guozhang Wang <[email protected]> Closes #1270 from jklukas/streams-doc-fix Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/18dd1986 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/18dd1986 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/18dd1986 Branch: refs/heads/trunk Commit: 18dd1986bd354e8c7d75982112fad848780a6b33 Parents: a02c8aa Author: Jeff Klukas <[email protected]> Authored: Tue Apr 26 09:11:40 2016 -0700 Committer: Guozhang Wang <[email protected]> Committed: Tue Apr 26 09:11:40 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/kafka/streams/StreamsConfig.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/18dd1986/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java ---------------------------------------------------------------------- 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 3e0f955..99eb58f 100644 --- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java +++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java @@ -63,7 +63,7 @@ public class StreamsConfig extends AbstractConfig { public static final String NUM_STREAM_THREADS_CONFIG = "num.stream.threads"; private static final String NUM_STREAM_THREADS_DOC = "The number of threads to execute stream processing."; - /** <code>num.stream.threads</code> */ + /** <code>num.standby.replicas</code> */ public static final String NUM_STANDBY_REPLICAS_CONFIG = "num.standby.replicas"; private static final String NUM_STANDBY_REPLICAS_DOC = "The number of standby replicas for each task."; @@ -91,11 +91,11 @@ public class StreamsConfig extends AbstractConfig { public static final String REPLICATION_FACTOR_CONFIG = "replication.factor"; public static final String REPLICATION_FACTOR_DOC = "The replication factor for change log topics and repartition topics created by the stream processing application."; - /** <code>replication.factor</code> */ + /** <code>key.serde</code> */ public static final String KEY_SERDE_CLASS_CONFIG = "key.serde"; public static final String KEY_SERDE_CLASS_DOC = "Serializer / deserializer class for key that implements the <code>Serde</code> interface."; - /** <code>replication.factor</code> */ + /** <code>value.serde</code> */ public static final String VALUE_SERDE_CLASS_CONFIG = "value.serde"; public static final String VALUE_SERDE_CLASS_DOC = "Serializer / deserializer class for value that implements the <code>Serde</code> interface.";
