Package org.apache.storm.perf
Class KafkaClientSpoutNullBoltTopo
java.lang.Object
org.apache.storm.perf.KafkaClientSpoutNullBoltTopo
Benchmark topology for measuring spout read/emit/ack performance. The spout reads and emits tuples. The bolt acks and discards received
 tuples.
- 
Field SummaryFields
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic StormTopologygetTopology(Map<String, Object> config) Create and configure the topology.static voidStart the topology.
- 
Field Details- 
SPOUT_NUM- See Also:
 
- 
BOLT_NUM- See Also:
 
- 
BOOTSTRAP_SERVERS- See Also:
 
- 
KAFKA_TOPIC- See Also:
 
- 
PROCESSING_GUARANTEE- See Also:
 
- 
OFFSET_COMMIT_PERIOD_MS- See Also:
 
- 
DEFAULT_SPOUT_NUMpublic static final int DEFAULT_SPOUT_NUM- See Also:
 
- 
DEFAULT_BOLT_NUMpublic static final int DEFAULT_BOLT_NUM- See Also:
 
- 
TOPOLOGY_NAME
- 
SPOUT_ID- See Also:
 
- 
BOLT_ID- See Also:
 
 
- 
- 
Constructor Details- 
KafkaClientSpoutNullBoltTopopublic KafkaClientSpoutNullBoltTopo()
 
- 
- 
Method Details- 
getTopologyCreate and configure the topology.
- 
mainStart the topology.- Throws:
- Exception
 
 
-