Package org.apache.storm.kafka.spout

# Class KafkaSpoutTopologyMainWildcardTopics

java.lang.Object
org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopics
org.apache.storm.kafka.spout.KafkaSpoutTopologyMainWildcardTopics

public class KafkaSpoutTopologyMainWildcardTopics extends KafkaSpoutTopologyMainNamedTopics
This example is similar to `KafkaSpoutTopologyMainNamedTopics`, but demonstrates subscribing to Kafka topics with a regex.

- ## Field Summary

  ### Fields inherited from class org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopics

  `TOPIC_0, TOPIC_1, TOPIC_2`

- ## Constructor Summary

  Constructors
  Constructor
  Description
  `KafkaSpoutTopologyMainWildcardTopics()`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `protected KafkaSpoutConfig<String,String>`
  `getKafkaSpoutConfig(String bootstrapServers)`
  `protected StormTopology`
  `getTopologyKafkaSpout(KafkaSpoutConfig<String,String> spoutConfig)`
  `static void`
  `main(String[] args)`

  ### Methods inherited from class org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopics

  `getConfig, getRetryService, runMain`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- ## Constructor Details

  - ### KafkaSpoutTopologyMainWildcardTopics

    public KafkaSpoutTopologyMainWildcardTopics()

- ## Method Details

  - ### main

    public static void main(String[] args) throws Exception
    Throws:
      `Exception`

  - ### getTopologyKafkaSpout

    protected StormTopology getTopologyKafkaSpout(KafkaSpoutConfig<String,String> spoutConfig)
    Overrides:
      `getTopologyKafkaSpout` in class `KafkaSpoutTopologyMainNamedTopics`

  - ### getKafkaSpoutConfig

    protected KafkaSpoutConfig<String,String> getKafkaSpoutConfig(String bootstrapServers)
    Overrides:
      `getKafkaSpoutConfig` in class `KafkaSpoutTopologyMainNamedTopics`