Package org.apache.storm.perf
Class KafkaClientSpoutNullBoltTopo
- java.lang.Object
-
- org.apache.storm.perf.KafkaClientSpoutNullBoltTopo
-
public class KafkaClientSpoutNullBoltTopo extends Object
Benchmark topology for measuring spout read/emit/ack performance. The spout reads and emits tuples. The bolt acks and discards received tuples.
-
-
Field Summary
Fields Modifier and Type Field Description static StringBOLT_IDstatic StringBOLT_NUMstatic StringBOOTSTRAP_SERVERSstatic intDEFAULT_BOLT_NUMstatic intDEFAULT_SPOUT_NUMstatic StringKAFKA_TOPICstatic StringOFFSET_COMMIT_PERIOD_MSstatic StringPROCESSING_GUARANTEEstatic StringSPOUT_IDstatic StringSPOUT_NUMstatic StringTOPOLOGY_NAME
-
Constructor Summary
Constructors Constructor Description KafkaClientSpoutNullBoltTopo()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static StormTopologygetTopology(Map<String,Object> config)Create and configure the topology.static voidmain(String[] args)Start the topology.
-
-
-
Field Detail
-
SPOUT_NUM
public static final String SPOUT_NUM
- See Also:
- Constant Field Values
-
BOLT_NUM
public static final String BOLT_NUM
- See Also:
- Constant Field Values
-
BOOTSTRAP_SERVERS
public static final String BOOTSTRAP_SERVERS
- See Also:
- Constant Field Values
-
KAFKA_TOPIC
public static final String KAFKA_TOPIC
- See Also:
- Constant Field Values
-
PROCESSING_GUARANTEE
public static final String PROCESSING_GUARANTEE
- See Also:
- Constant Field Values
-
OFFSET_COMMIT_PERIOD_MS
public static final String OFFSET_COMMIT_PERIOD_MS
- See Also:
- Constant Field Values
-
DEFAULT_SPOUT_NUM
public static final int DEFAULT_SPOUT_NUM
- See Also:
- Constant Field Values
-
DEFAULT_BOLT_NUM
public static final int DEFAULT_BOLT_NUM
- See Also:
- Constant Field Values
-
TOPOLOGY_NAME
public static final String TOPOLOGY_NAME
-
SPOUT_ID
public static final String SPOUT_ID
- See Also:
- Constant Field Values
-
BOLT_ID
public static final String BOLT_ID
- See Also:
- Constant Field Values
-
-