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 Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic StormTopology
getTopology
(Map<String, Object> config) Create and configure the topology.static void
Start 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_NUM
public static final int DEFAULT_SPOUT_NUM- See Also:
-
DEFAULT_BOLT_NUM
public static final int DEFAULT_BOLT_NUM- See Also:
-
TOPOLOGY_NAME
-
SPOUT_ID
- See Also:
-
BOLT_ID
- See Also:
-
-
Constructor Details
-
KafkaClientSpoutNullBoltTopo
public KafkaClientSpoutNullBoltTopo()
-
-
Method Details
-
getTopology
Create and configure the topology. -
main
Start the topology.- Throws:
Exception
-