kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject kafka git commit: MINOR: streams javadoc corrections
Date Mon, 07 Mar 2016 19:32:37 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 25bde48e6 -> 5761a9ec7


MINOR: streams javadoc corrections

Author: Manikumar reddy O <manikumar.reddy@gmail.com>

Reviewers: Gwen Shapira

Closes #1019 from omkreddy/JAVADOC


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5761a9ec
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/5761a9ec
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/5761a9ec

Branch: refs/heads/trunk
Commit: 5761a9ec7285cae9167fcb10f0e800e2a048511a
Parents: 25bde48
Author: Manikumar reddy O <manikumar.reddy@gmail.com>
Authored: Mon Mar 7 11:32:34 2016 -0800
Committer: Gwen Shapira <cshapi@gmail.com>
Committed: Mon Mar 7 11:32:34 2016 -0800

----------------------------------------------------------------------
 .../org/apache/kafka/streams/processor/TopologyBuilder.java  | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/5761a9ec/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java
b/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java
index 3ef1b0a..7e3cab9 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/TopologyBuilder.java
@@ -204,7 +204,7 @@ public class TopologyBuilder {
 
     /**
      * Add a new source that consumes the named topics and forwards the messages to child
processor and/or sink nodes.
-     * The sink will use the specified key and value deserializers.
+     * The source will use the specified key and value deserializers.
      *
      * @param name the unique name of the source used to reference this node when
      * {@link #addProcessor(String, ProcessorSupplier, String...) adding processor children}.
@@ -284,12 +284,6 @@ public class TopologyBuilder {
     /**
      * Add a new sink that forwards messages from upstream parent processor and/or source
nodes to the named Kafka topic.
      * The sink will use the specified key and value serializers.
-     * <p>
-     * The sink will also use the specified {@link StreamPartitioner} to determine how messages
are distributed among
-     * the named Kafka topic's partitions. Such control is often useful with topologies that
use
-     * {@link #addStateStore(StateStoreSupplier, String...) state stores}
-     * in its processors. In most other cases, however, a partitioner need not be specified
and Kafka will automatically distribute
-     * messages among partitions using Kafka's default partitioning logic.
      *
      * @param name the unique name of the sink
      * @param topic the name of the Kafka topic to which this sink should write its messages


Mime
View raw message