Open Kilda Java Documentation
org.openkilda.floodlight.kafka.TestAwareConsumer Member List

This is the complete list of members for org.openkilda.floodlight.kafka.TestAwareConsumer, including all inherited members.

Consumer(KafkaConsumerConfig kafkaConfig, ExecutorService handlersPool, RecordHandler.Factory handlerFactory, ISwitchManager switchManager, String topic, String... moreTopics)org.openkilda.floodlight.kafka.Consumer
handle(ConsumerRecord< String, String > record)org.openkilda.floodlight.kafka.TestAwareConsumerprotected
run()org.openkilda.floodlight.kafka.Consumer
TestAwareConsumer(ConsumerContext context, KafkaConsumerConfig kafkaConfig, ExecutorService handlersPool, Factory handlerFactory, ISwitchManager switchManager, String topic, String... moreTopics)org.openkilda.floodlight.kafka.TestAwareConsumer