Package su.onno.kafka

Class OnnoKafkaAutoConfiguration

java.lang.Object

su.onno.kafka.OnnoKafkaAutoConfiguration

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

Constructor Summary

Constructors

Constructor	Description
OnnoKafkaAutoConfiguration()

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, OnnoKafkaProperties properties)
RemoteRefClient	remoteRefClient(ServiceRegistry serviceRegistry, org.springframework.web.client.RestClient.Builder restClientBuilder)
ServiceRegistry	serviceRegistry(OnnoKafkaProperties properties)

Methods inherited from class java.lang.Object

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

Constructor Details

OnnoKafkaAutoConfiguration

public OnnoKafkaAutoConfiguration()

Method Details

serviceRegistry

@Bean
public ServiceRegistry serviceRegistry(OnnoKafkaProperties 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,
 OnnoKafkaProperties properties)