Uses of Interface
org.apache.storm.kafka.spout.subscription.ManualPartitioner
Package
Description
-
Uses of ManualPartitioner in org.apache.storm.kafka.spout
ModifierConstructorDescriptionBuilder
(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
ModifierConstructorDescriptionBuilder
(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
Modifier 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
ModifierConstructorDescriptionBuilder
(String bootstrapServers, TopicFilter topicFilter, ManualPartitioner topicPartitioner)