Package es.kukenan.smartfi.kafka.config

Class TopicConfig

java.lang.Object

es.kukenan.smartfi.kafka.config.TopicConfig

@Configuration
public class TopicConfig
extends Object

Create the configuration needed to exchange requests and responses through the mail channel.

Field Summary

Fields

Modifier and Type	Field	Description
private String	bootstrapAddress	Create the configuration needed to exchange requests and responses through the mail channel.
private String	topicName	Create the configuration needed to exchange requests and responses through the mail channel.

Constructor Summary

Constructors

Constructor	Description
TopicConfig()

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.clients.admin.NewTopic	eventTopic()	EventConsumerFactory.
org.springframework.kafka.core.KafkaAdmin	kafkaAdmin()	EventConsumerFactory.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

bootstrapAddress

@Value("${spring.kafka.bootstrap.server}")
private String bootstrapAddress

Create the configuration needed to exchange requests and responses through the mail channel.

topicName

@Value("${topic.exchange.name}")
private String topicName

Create the configuration needed to exchange requests and responses through the mail channel.

Constructor Details

TopicConfig

public TopicConfig()

Method Details

eventTopic

@Bean
public org.apache.kafka.clients.admin.NewTopic eventTopic()

EventConsumerFactory.

Returns:

consumer Factory.

kafkaAdmin

@Bean
public org.springframework.kafka.core.KafkaAdmin kafkaAdmin()

EventConsumerFactory.

Returns:

consumer Factory.