org.openkilda.northbound.config.MessageConsumerConfig Class Reference

Public Member Functions
Map< String, Object >	consumerConfigs ()
ConsumerFactory< String, String >	consumerFactory ()
ConcurrentKafkaListenerContainerFactory< String, String >	kafkaListenerContainerFactory ()
MessageConsumer	messageConsumer ()
HealthCheckMessageConsumer	healthCheckMessageConsumer ()

Detailed Description

The Kafka message consumer configuration.

Definition at line 43 of file MessageConsumerConfig.java.

Member Function Documentation

consumerConfigs()

Map<String, Object> org.openkilda.northbound.config.MessageConsumerConfig.consumerConfigs

(

)

Kafka consumer configuration bean. This Map is used by MessageConsumerConfig#consumerFactory.

Returns

kafka properties

Definition at line 67 of file MessageConsumerConfig.java.

consumerFactory()

ConsumerFactory<String, String> org.openkilda.northbound.config.MessageConsumerConfig.consumerFactory

(

)

Kafka consumer factory bean. The strategy to produce a org.apache.kafka.clients.consumer.Consumer instance with MessageConsumerConfig#consumerConfigs on each org.springframework.kafka.core.DefaultKafkaConsumerFactory#createConsumer invocation.

Returns

kafka consumer factory

Definition at line 90 of file MessageConsumerConfig.java.

healthCheckMessageConsumer()

HealthCheckMessageConsumer org.openkilda.northbound.config.MessageConsumerConfig.healthCheckMessageConsumer

(

)

Kafka message consumer bean. Instance of KafkaHealthCheckMessageConsumer contains org.springframework.kafka.annotation.KafkaListener to be run in org.springframework.kafka.listener.ConcurrentMessageListenerContainer.

Returns

kafka health-check message consumer

Definition at line 131 of file MessageConsumerConfig.java.

kafkaListenerContainerFactory()

ConcurrentKafkaListenerContainerFactory<String, String> org.openkilda.northbound.config.MessageConsumerConfig.kafkaListenerContainerFactory

(

)

Kafka listener container factory bean. Returned instance builds org.springframework.kafka.listener.ConcurrentMessageListenerContainer using the org.apache.kafka.clients.consumer.Consumer.

Returns

kafka listener container factory

Definition at line 102 of file MessageConsumerConfig.java.

messageConsumer()

MessageConsumer org.openkilda.northbound.config.MessageConsumerConfig.messageConsumer

(

)

Kafka message consumer bean. Instance of org.openkilda.northbound.messaging.kafka.KafkaMessageConsumer contains org.springframework.kafka.annotation.KafkaListener to be run in org.springframework.kafka.listener.ConcurrentMessageListenerContainer.

Returns

kafka message consumer

Definition at line 119 of file MessageConsumerConfig.java.

---

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

• /Users/kevin/Desktop/Kilda/open-kilda-develop/services/src/northbound/src/main/java/org/openkilda/northbound/config/MessageConsumerConfig.java