![]() |
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.