Open Kilda Java Documentation
Public Member Functions | List of all members
org.openkilda.northbound.config.MessageProducerConfig Class Reference

Public Member Functions

Map< String, Object > producerConfigs ()
 
ProducerFactory< String, String > producerFactory ()
 
KafkaTemplate< String, String > kafkaTemplate ()
 
MessageProducer messageProducer ()
 

Detailed Description

Kafka message producer configuration.

Definition at line 39 of file MessageProducerConfig.java.

Member Function Documentation

◆ kafkaTemplate()

KafkaTemplate<String, String> org.openkilda.northbound.config.MessageProducerConfig.kafkaTemplate ( )

Kafka template bean. Wraps org.apache.kafka.clients.producer.KafkaProducer.

Returns
kafka template

Definition at line 86 of file MessageProducerConfig.java.

◆ messageProducer()

MessageProducer org.openkilda.northbound.config.MessageProducerConfig.messageProducer ( )

Kafka message producer bean. Instance of org.openkilda.northbound.messaging.kafka.KafkaMessageProducer contains org.springframework.kafka.core.KafkaTemplate to be used to send messages.

Returns
kafka message producer

Definition at line 99 of file MessageProducerConfig.java.

◆ producerConfigs()

Map<String, Object> org.openkilda.northbound.config.MessageProducerConfig.producerConfigs ( )

Kafka producer config bean. This Map is used by MessageProducerConfig#producerFactory.

Returns
kafka properties bean

Definition at line 53 of file MessageProducerConfig.java.

◆ producerFactory()

ProducerFactory<String, String> org.openkilda.northbound.config.MessageProducerConfig.producerFactory ( )

Kafka producer factory bean. The strategy to produce a org.apache.kafka.clients.producer.Producer instance with MessageProducerConfig#producerConfigs on each org.springframework.kafka.core.DefaultKafkaProducerFactory#createProducer invocation.

Returns
kafka producer factory

Definition at line 75 of file MessageProducerConfig.java.

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