Uses of Interface
org.apache.storm.kafka.spout.subscription.ManualPartitioner
Packages that use ManualPartitioner
Package
Description
-
Uses of ManualPartitioner in org.apache.storm.kafka.spout
Constructors in org.apache.storm.kafka.spout with parameters of type ManualPartitionerModifierConstructorDescriptionBuilder
(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 ManualPartitionerConstructors in org.apache.storm.kafka.spout.internal with parameters of type ManualPartitionerModifierConstructorDescriptionBuilder
(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 ManualPartitionerModifier and TypeClassDescriptionclass
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 ManualPartitionerModifierConstructorDescriptionBuilder
(String bootstrapServers, TopicFilter topicFilter, ManualPartitioner topicPartitioner)