Class KafkaTridentSpoutConfig<K,V>

java.lang.Object
org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig<K,V>
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig<K,V>
All Implemented Interfaces:
Serializable

public class KafkaTridentSpoutConfig<K,V> extends CommonKafkaSpoutConfig<K,V>
Defines the required Kafka-related configuration for the Trident spouts.
See Also:
  • Constructor Details

  • Method Details

    • builder

      public static KafkaTridentSpoutConfig.Builder<String,String> builder(String bootstrapServers, String... topics)
      Factory method that creates a Builder with String key/value deserializers.
      Parameters:
      bootstrapServers - The bootstrap servers for the consumer
      topics - The topics to subscribe to
      Returns:
      The new builder
    • builder

      public static KafkaTridentSpoutConfig.Builder<String,String> builder(String bootstrapServers, Set<String> topics)
      Factory method that creates a Builder with String key/value deserializers.
      Parameters:
      bootstrapServers - The bootstrap servers for the consumer
      topics - The topics to subscribe to
      Returns:
      The new builder
    • builder

      public static KafkaTridentSpoutConfig.Builder<String,String> builder(String bootstrapServers, Pattern topics)
      Factory method that creates a Builder with String key/value deserializers.
      Parameters:
      bootstrapServers - The bootstrap servers for the consumer
      topics - The topic pattern to subscribe to
      Returns:
      The new builder