org.axonframework.boot.autoconfig

Class KafkaAutoConfiguration

java.lang.Object

org.axonframework.boot.autoconfig.KafkaAutoConfiguration

@Configuration
 @ConditionalOnClass(value=KafkaPublisher.class)
 @EnableConfigurationProperties(value=KafkaProperties.class)
public class KafkaAutoConfiguration
extends Object

Auto-configuration for Apache Kafka.

Since:

3.0

Author:

Nakul Mishra

Constructor Summary

Constructors

Constructor and Description
KafkaAutoConfiguration(KafkaProperties properties)

Method Summary

Modifier and Type	Method and Description
ConsumerFactory<String,byte[]>	kafkaConsumerFactory()
Fetcher	kafkaFetcher(ConsumerFactory<String,byte[]> consumerFactory, KafkaMessageConverter<String,byte[]> messageConverter)
KafkaMessageConverter<String,byte[]>	kafkaMessageConverter(Serializer eventSerializer)
KafkaMessageSource	kafkaMessageSource(Fetcher fetcher)
KafkaPublisher<String,byte[]>	kafkaPublisher(ProducerFactory<String,byte[]> producerFactory, EventBus eventBus, KafkaMessageConverter<String,byte[]> messageConverter, AxonConfiguration configuration)
ProducerFactory<String,byte[]>	producerFactory()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaAutoConfiguration

public KafkaAutoConfiguration(KafkaProperties properties)

Method Detail

producerFactory

@ConditionalOnMissingBean
 @ConditionalOnProperty(value="axon.kafka.producer.transaction-id-prefix")
 @Bean
public ProducerFactory<String,byte[]> producerFactory()

kafkaConsumerFactory

@ConditionalOnMissingBean
 @Bean
 @ConditionalOnProperty(value="axon.kafka.consumer.group-id")
public ConsumerFactory<String,byte[]> kafkaConsumerFactory()

kafkaPublisher

@ConditionalOnMissingBean
 @Bean(initMethod="start",
      destroyMethod="shutDown")
 @ConditionalOnBean(value=ProducerFactory.class)
public KafkaPublisher<String,byte[]> kafkaPublisher(ProducerFactory<String,byte[]> producerFactory,
                                                                                                                                                                                              EventBus eventBus,
                                                                                                                                                                                              KafkaMessageConverter<String,byte[]> messageConverter,
                                                                                                                                                                                              AxonConfiguration configuration)

kafkaFetcher

@ConditionalOnMissingBean
 @Bean(destroyMethod="shutdown")
 @ConditionalOnBean(value={ConsumerFactory.class,KafkaMessageConverter.class})
public Fetcher kafkaFetcher(ConsumerFactory<String,byte[]> consumerFactory,
                                                                                                                                                                         KafkaMessageConverter<String,byte[]> messageConverter)

kafkaMessageSource

@ConditionalOnMissingBean
 @Bean
 @ConditionalOnBean(value=ConsumerFactory.class)
public KafkaMessageSource kafkaMessageSource(Fetcher fetcher)

kafkaMessageConverter

@ConditionalOnMissingBean
 @Bean
public KafkaMessageConverter<String,byte[]> kafkaMessageConverter(@Qualifier(value="eventSerializer")
                                                                                                     Serializer eventSerializer)