![]() |
Open Kilda Java Documentation
|
Public Member Functions | |
| Producer (KafkaProducerConfig kafkaConfig) | |
| synchronized void | enableGuaranteedOrder (String topic) |
| synchronized void | disableGuaranteedOrder (String topic) |
| synchronized void | disableGuaranteedOrder (String topic, long transitionPeriod) |
| void | sendMessageAndTrack (String topic, Message message) |
| SendStatus | sendMessage (String topic, Message message) |
Definition at line 30 of file Producer.java.
| org.openkilda.floodlight.kafka.producer.Producer.Producer | ( | KafkaProducerConfig | kafkaConfig | ) |
Definition at line 37 of file Producer.java.
| synchronized void org.openkilda.floodlight.kafka.producer.Producer.disableGuaranteedOrder | ( | String | topic | ) |
Disable guaranteed message order for topic.
Definition at line 57 of file Producer.java.
| synchronized void org.openkilda.floodlight.kafka.producer.Producer.disableGuaranteedOrder | ( | String | topic, |
| long | transitionPeriod | ||
| ) |
Disable guaranteed message order for topic, with defined transition period.
Definition at line 67 of file Producer.java.
| synchronized void org.openkilda.floodlight.kafka.producer.Producer.enableGuaranteedOrder | ( | String | topic | ) |
Enable guaranteed message order for topic.
Definition at line 48 of file Producer.java.
| SendStatus org.openkilda.floodlight.kafka.producer.Producer.sendMessage | ( | String | topic, |
| Message | message | ||
| ) |
Definition at line 77 of file Producer.java.
| void org.openkilda.floodlight.kafka.producer.Producer.sendMessageAndTrack | ( | String | topic, |
| Message | message | ||
| ) |
Definition at line 73 of file Producer.java.