Package com.onec.kafka

Class OnecKafkaAutoConfiguration

java.lang.Object

com.onec.kafka.OnecKafkaAutoConfiguration

@AutoConfiguration
@ConditionalOnClass(org.springframework.kafka.core.KafkaTemplate.class)
@ConditionalOnBean({OutboxWriter.class,org.springframework.kafka.core.KafkaTemplate.class})
@ConditionalOnProperty(prefix="onec.kafka",
                       name="enabled",
                       havingValue="true",
                       matchIfMissing=true)
@EnableConfigurationProperties(OnecKafkaProperties.class)
public class OnecKafkaAutoConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
OnecKafkaAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
OutboxRelay	outboxRelay(OutboxWriter outboxWriter, org.springframework.kafka.core.KafkaTemplate<String,String> kafkaTemplate, com.fasterxml.jackson.databind.ObjectMapper objectMapper, OnecKafkaProperties properties)
RemoteRefClient	remoteRefClient(ServiceRegistry serviceRegistry, org.springframework.web.client.RestClient.Builder restClientBuilder)
ServiceRegistry	serviceRegistry(OnecKafkaProperties properties)

Methods inherited from class java.lang.Object

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

Constructor Details

OnecKafkaAutoConfiguration

public OnecKafkaAutoConfiguration()

Method Details

serviceRegistry

@Bean
public ServiceRegistry serviceRegistry(OnecKafkaProperties properties)

remoteRefClient

@Bean
public RemoteRefClient remoteRefClient(ServiceRegistry serviceRegistry,
 org.springframework.web.client.RestClient.Builder restClientBuilder)

outboxRelay

@Bean
public OutboxRelay outboxRelay(OutboxWriter outboxWriter,
 org.springframework.kafka.core.KafkaTemplate<String,String> kafkaTemplate,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 OnecKafkaProperties properties)