org.openkilda.wfm.SimpleKafkaTest Class Reference

Public Member Functions
void	setup () throws Exception
void	teardown () throws Exception
void	shouldWriteThenRead () throws Exception

Static Public Member Functions
static void	allocateConfig () throws ConfigurationException, CmdLineException

Static Public Attributes
static final String	topic = "simple-kafka"

Detailed Description

This class is mostly an example of how to startup zookeeper/kafka and send/receive messages. It should be useful when developing Storm Topologies that have a Kafka Spout

Definition at line 51 of file SimpleKafkaTest.java.

Member Function Documentation

allocateConfig()

static void org.openkilda.wfm.SimpleKafkaTest.allocateConfig ( ) throws ConfigurationException, CmdLineException

static

Definition at line 63 of file SimpleKafkaTest.java.

setup()

void org.openkilda.wfm.SimpleKafkaTest.setup

(

)

throws Exception

Definition at line 70 of file SimpleKafkaTest.java.

shouldWriteThenRead()

void org.openkilda.wfm.SimpleKafkaTest.shouldWriteThenRead

(

)

throws Exception

Definition at line 83 of file SimpleKafkaTest.java.

teardown()

void org.openkilda.wfm.SimpleKafkaTest.teardown

(

)

throws Exception

Definition at line 76 of file SimpleKafkaTest.java.

Member Data Documentation

topic

final String org.openkilda.wfm.SimpleKafkaTest.topic = "simple-kafka"

static

Definition at line 52 of file SimpleKafkaTest.java.

---

The documentation for this class was generated from the following file:

• /Users/kevin/Desktop/Kilda/open-kilda-develop/services/wfm/src/test/java/org/openkilda/wfm/SimpleKafkaTest.java