Uses of Interface
org.apache.storm.kafka.spout.subscription.ManualPartitioner
-
Packages that use ManualPartitioner Package Description org.apache.storm.kafka.spout org.apache.storm.kafka.spout.internal org.apache.storm.kafka.spout.subscription org.apache.storm.kafka.spout.trident -
-
Uses of ManualPartitioner in org.apache.storm.kafka.spout
Constructors in org.apache.storm.kafka.spout with parameters of type ManualPartitioner Constructor Description Builder(String bootstrapServers, TopicFilter topicFilter, ManualPartitioner topicPartitioner)
Create a KafkaSpoutConfig builder with default property values and no key/value deserializers. -
Uses of ManualPartitioner in org.apache.storm.kafka.spout.internal
Methods in org.apache.storm.kafka.spout.internal that return ManualPartitioner Modifier and Type Method Description ManualPartitioner
CommonKafkaSpoutConfig. getTopicPartitioner()
Constructors in org.apache.storm.kafka.spout.internal with parameters of type ManualPartitioner Constructor Description Builder(String bootstrapServers, TopicFilter topicFilter, ManualPartitioner topicPartitioner)
Create a KafkaSpoutConfig builder with default property values and no key/value deserializers. -
Uses of ManualPartitioner in org.apache.storm.kafka.spout.subscription
Classes in org.apache.storm.kafka.spout.subscription that implement ManualPartitioner Modifier and Type Class Description class
RoundRobinManualPartitioner
Assign partitions in a round robin fashion for all spouts, not just the ones that are alive. -
Uses of ManualPartitioner in org.apache.storm.kafka.spout.trident
Constructors in org.apache.storm.kafka.spout.trident with parameters of type ManualPartitioner Constructor Description Builder(String bootstrapServers, TopicFilter topicFilter, ManualPartitioner topicPartitioner)
-