Package org.apache.storm.kafka.spout

Class KafkaSpoutTopologyMainNamedTopics

java.lang.Object

org.apache.storm.kafka.spout.KafkaSpoutTopologyMainNamedTopics

Direct Known Subclasses:

KafkaSpoutTopologyMainWildcardTopics

public class KafkaSpoutTopologyMainNamedTopics
extends Object

This example sets up 3 topologies to put data in Kafka via the KafkaBolt, and shows how to set up a topology that reads from some Kafka topics using the KafkaSpout.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TOPIC_0
static final String	TOPIC_1
static final String	TOPIC_2

Constructor Summary

Constructors

Constructor	Description
KafkaSpoutTopologyMainNamedTopics()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

TOPIC_0

public static final String TOPIC_0

See Also:

• Constant Field Values

TOPIC_1

public static final String TOPIC_1

See Also:

• Constant Field Values

TOPIC_2

public static final String TOPIC_2

See Also:

• Constant Field Values

Constructor Details

KafkaSpoutTopologyMainNamedTopics

public KafkaSpoutTopologyMainNamedTopics()

Method Details

main

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

Throws:

Exception

runMain

protected void runMain(String[] args)
                throws Exception

Throws:

Exception

getConfig

protected Config getConfig()

getTopologyKafkaSpout

protected StormTopology getTopologyKafkaSpout(KafkaSpoutConfig<String,String> spoutConfig)

getKafkaSpoutConfig

protected KafkaSpoutConfig<String,String> getKafkaSpoutConfig(String bootstrapServers)

getRetryService

protected KafkaSpoutRetryService getRetryService()