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