storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From s...@apache.org
Subject [storm] 01/07: MINOR: Remove reference to deleted Subscription interface in storm-kafka-client docs
Date Wed, 30 Jan 2019 11:41:27 GMT
This is an automated email from the ASF dual-hosted git repository.

srdo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git

commit c466f5f563cf675c3b3c08701e86e4a317741641
Author: Stig Rohde Døssing <srdo@apache.org>
AuthorDate: Wed Jan 23 19:10:07 2019 +0100

    MINOR: Remove reference to deleted Subscription interface in storm-kafka-client docs
---
 docs/storm-kafka-client.md | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/docs/storm-kafka-client.md b/docs/storm-kafka-client.md
index 1123bdd..73c88c7 100644
--- a/docs/storm-kafka-client.md
+++ b/docs/storm-kafka-client.md
@@ -245,9 +245,13 @@ streams.  If you are doing this for Trident a value must be in the List
returned
 otherwise trident can throw exceptions.
 
 
-### Manual Partition Assigment (ADVANCED)
+### Manual Partition Assignment (ADVANCED)
 
-By default the KafkaSpout instances will be assigned partitions using a round robin strategy.
If you need to customize partition assignment, you must implement the `ManualPartitioner`
interface. The implementation can be passed to the `ManualPartitionSubscription` constructor,
and the `Subscription` can then be set in the `KafkaSpoutConfig` via the `KafkaSpoutConfig.Builder`
constructor. Please take care when supplying a custom implementation, since an incorrect `ManualPartitioner`
imple [...]
+By default the KafkaSpout instances will be assigned partitions using a round robin strategy.
If you need to customize partition assignment, you must implement the `ManualPartitioner`
interface. You can pass your implementation to the `KafkaSpoutConfig.Builder` constructor.
Please take care when supplying a custom implementation, since an incorrect `ManualPartitioner`
implementation could leave some partitions unread, or concurrently read by multiple spout
instances. See the `RoundRobinM [...]
+
+### Manual partition discovery
+
+You can customize how the spout discovers existing partitions, by implementing the `TopicFilter`
interface. Storm-kafka-client ships with a few implementations. Like `ManualPartitioner`,
you can pass your implementation to the `KafkaSpoutConfig.Builder` constructor. Note that
the `TopicFilter` is only responsible for discovering partitions, deciding which of the discovered
partitions to subscribe to is the responsibility of `ManualPartitioner`.
 
 ## Using storm-kafka-client with different versions of kafka
 


Mime
View raw message