From 7ceac7955c95812cac7530348edeba6ed8e8a1af Mon Sep 17 00:00:00 2001 From: Manikumar reddy O Date: Mon, 7 Mar 2016 16:21:44 +0530 Subject: [PATCH] MINOR: streams javadoc corrections --- .../apache/kafka/streams/processor/TopologyBuilder.java | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) 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 3ef1b0a49cf4d..7e3cab9054e39 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 final TopologyBuilder addSource(String name, String... topics) { /** * 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 final TopologyBuilder addSink(String name, String topic, StreamPartitione /** * 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. - *

- * 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