Open Kilda Java Documentation
org.openkilda.floodlight.kafka.producer.Producer Class Reference
Inheritance diagram for org.openkilda.floodlight.kafka.producer.Producer:
org.openkilda.floodlight.kafka.TestAwareProducer

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)
 

Detailed Description

Definition at line 30 of file Producer.java.

Constructor & Destructor Documentation

◆ Producer()

org.openkilda.floodlight.kafka.producer.Producer.Producer ( KafkaProducerConfig  kafkaConfig)

Definition at line 37 of file Producer.java.

Member Function Documentation

◆ disableGuaranteedOrder() [1/2]

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.

◆ disableGuaranteedOrder() [2/2]

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.

◆ enableGuaranteedOrder()

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.

◆ sendMessage()

SendStatus org.openkilda.floodlight.kafka.producer.Producer.sendMessage ( String  topic,
Message  message 
)

Definition at line 77 of file Producer.java.

◆ sendMessageAndTrack()

void org.openkilda.floodlight.kafka.producer.Producer.sendMessageAndTrack ( String  topic,
Message  message 
)

Definition at line 73 of file Producer.java.


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