| Interface | Description |
|---|---|
| ManualPartitioner |
A function used to assign partitions to this spout.
|
| TopicFilter |
| Class | Description |
|---|---|
| NamedTopicFilter |
Filter that returns all partitions for the specified topics.
|
| PatternTopicFilter |
Filter that returns all partitions for topics matching the given
Pattern. |
| RoundRobinManualPartitioner |
Assign partitions in a round robin fashion for all spouts, not just the ones that are alive.
|
| TopicAssigner |
Handles assigning partitions to the consumer and updating the rebalance listener.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.