org.openkilda.floodlight.kafka.KafkaConsumerConfig Interface Reference

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

Public Member Functions
String	getGroupId ()
String	getTestingMode ()
int	getExecutorCount ()
long	getAutoCommitInterval ()
default boolean	isTestingMode ()
default Properties	createKafkaConsumerProperties ()
Public Member Functions inherited from org.openkilda.floodlight.config.KafkaFloodlightConfig
String	getBootstrapServers ()

Additional Inherited Members
Public Attributes inherited from org.openkilda.config.KafkaConsumerGroupConfig
String	KAFKA_CONSUMER_GROUP_MAPPING = "KAFKA_GROUP"

Detailed Description

WARNING! Do not use '.' in option's keys. FL will not collect such option from config.

Definition at line 33 of file KafkaConsumerConfig.java.

Member Function Documentation

createKafkaConsumerProperties()

default Properties org.openkilda.floodlight.kafka.KafkaConsumerConfig.createKafkaConsumerProperties

(

)

Returns Kafka properties built with the configuration data for Consumer.

Definition at line 59 of file KafkaConsumerConfig.java.

getAutoCommitInterval()

long org.openkilda.floodlight.kafka.KafkaConsumerConfig.getAutoCommitInterval

(

)

getExecutorCount()

int org.openkilda.floodlight.kafka.KafkaConsumerConfig.getExecutorCount

(

)

getGroupId()

String org.openkilda.floodlight.kafka.KafkaConsumerConfig.getGroupId

(

)

getTestingMode()

String org.openkilda.floodlight.kafka.KafkaConsumerConfig.getTestingMode

(

)

isTestingMode()

default boolean org.openkilda.floodlight.kafka.KafkaConsumerConfig.isTestingMode

(

)

Definition at line 52 of file KafkaConsumerConfig.java.

---

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

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