org.openkilda.floodlight.kafka.Consumer Class Reference

Inheritance diagram for org.openkilda.floodlight.kafka.Consumer:

Classes
class	KafkaOffsetRegistry

Public Member Functions
	Consumer (KafkaConsumerConfig kafkaConfig, ExecutorService handlersPool, RecordHandler.Factory handlerFactory, ISwitchManager switchManager, String topic, String... moreTopics)
void	run ()

Protected Member Functions
void	handle (ConsumerRecord< String, String > record)

Detailed Description

Definition at line 42 of file Consumer.java.

Constructor & Destructor Documentation

Consumer()

org.openkilda.floodlight.kafka.Consumer.Consumer	(	KafkaConsumerConfig	kafkaConfig,
		ExecutorService	handlersPool,
		RecordHandler.Factory	handlerFactory,
		ISwitchManager	switchManager,
		String	topic,
		String...	moreTopics
	)

Definition at line 52 of file Consumer.java.

Member Function Documentation

handle()

void org.openkilda.floodlight.kafka.Consumer.handle ( ConsumerRecord< String, String >  record )

protected

Definition at line 115 of file Consumer.java.

run()

void org.openkilda.floodlight.kafka.Consumer.run

(

)

Definition at line 66 of file Consumer.java.

---

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

• /Users/kevin/Desktop/Kilda/open-kilda-develop/services/src/floodlight-modules/src/main/java/org/openkilda/floodlight/kafka/Consumer.java