org.openkilda.KafkaUtils Class Reference

Public Member Functions
	KafkaUtils () throws IOException
RecordMetadata	postMessage (String topic, Message message) throws IOException, ExecutionException, InterruptedException
void	pollMessage (String topic)
KafkaConsumer< String, String >	createConsumer ()
DumpStateManager	getStateDumpsFromBolts ()
CtrlResponse	clearTopologyComponentState (String topology, String componentId)
Properties	getConnectDefaults ()

Detailed Description

Definition at line 50 of file KafkaUtils.java.

Constructor & Destructor Documentation

KafkaUtils()

org.openkilda.KafkaUtils.KafkaUtils

(

)

throws IOException

Definition at line 55 of file KafkaUtils.java.

Member Function Documentation

clearTopologyComponentState()

CtrlResponse org.openkilda.KafkaUtils.clearTopologyComponentState	(	String	topology,
		String	componentId
	)

Sends a clearState ctrl request to the topology component.

Definition at line 154 of file KafkaUtils.java.

createConsumer()

KafkaConsumer<String, String> org.openkilda.KafkaUtils.createConsumer

(

)

Definition at line 88 of file KafkaUtils.java.

getConnectDefaults()

Properties org.openkilda.KafkaUtils.getConnectDefaults

(

)

Definition at line 194 of file KafkaUtils.java.

getStateDumpsFromBolts()

DumpStateManager org.openkilda.KafkaUtils.getStateDumpsFromBolts

(

)

Definition at line 102 of file KafkaUtils.java.

pollMessage()

void org.openkilda.KafkaUtils.pollMessage

(

String

topic

)

Definition at line 82 of file KafkaUtils.java.

postMessage()

RecordMetadata org.openkilda.KafkaUtils.postMessage	(	String	topic,
		Message	message
	)		throws IOException, ExecutionException, InterruptedException

Definition at line 63 of file KafkaUtils.java.

---

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

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