Package org.springframework.cloud.stream.binder.kafka.streams

Class KafkaStreamsBinderSupportAutoConfiguration

java.lang.Object

org.springframework.cloud.stream.binder.kafka.streams.KafkaStreamsBinderSupportAutoConfiguration

@Configuration
@EnableConfigurationProperties(KafkaStreamsExtendedBindingProperties.class)
@ConditionalOnBean(org.springframework.cloud.stream.binding.BindingService.class)
@AutoConfigureAfter(org.springframework.cloud.stream.config.BindingServiceConfiguration.class)
public class KafkaStreamsBinderSupportAutoConfiguration
extends Object

Kafka Streams binder configuration.

Author:

Marius Bogoevici, Soby Chacko, Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	KafkaStreamsBinderSupportAutoConfiguration.KafkaStreamsBinderMetricsConfiguration
protected class	KafkaStreamsBinderSupportAutoConfiguration.KafkaStreamsBinderMetricsConfigurationWithMultiBinder

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsBinderSupportAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
KafkaStreamsBinderConfigurationProperties	binderConfigurationProperties(org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties, org.springframework.core.env.ConfigurableEnvironment environment, org.springframework.cloud.stream.config.BindingServiceProperties properties, org.springframework.context.ConfigurableApplicationContext context)
CompositeNonNativeSerde	compositeNonNativeSerde(org.springframework.messaging.converter.CompositeMessageConverter compositeMessageConverterFactory)
EncodingDecodingBindAdviceHandler	encodingDecodingBindAdviceHandler()
GlobalKTableBoundElementFactory	globalKTableBoundElementFactory(org.springframework.cloud.stream.config.BindingServiceProperties properties, EncodingDecodingBindAdviceHandler encodingDecodingBindAdviceHandler, KafkaStreamsBindingInformationCatalogue KafkaStreamsBindingInformationCatalogue)
InteractiveQueryService	interactiveQueryServices(KafkaStreamsRegistry kafkaStreamsRegistry, KafkaStreamsBinderConfigurationProperties properties)
KafkaStreamsBindingInformationCatalogue	kafkaStreamsBindingInformationCatalogue()
org.springframework.kafka.config.KafkaStreamsConfiguration	kafkaStreamsConfiguration(KafkaStreamsBinderConfigurationProperties properties, org.springframework.core.env.Environment environment)
KafkaStreamsFunctionProcessor	kafkaStreamsFunctionProcessor(org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties, KafkaStreamsExtendedBindingProperties kafkaStreamsExtendedBindingProperties, KeyValueSerdeResolver keyValueSerdeResolver, KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue, KafkaStreamsMessageConversionDelegate kafkaStreamsMessageConversionDelegate, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.core.CleanupConfig> cleanupConfig, org.springframework.cloud.stream.function.StreamFunctionProperties streamFunctionProperties, KafkaStreamsBinderConfigurationProperties kafkaStreamsBinderConfigurationProperties, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.config.StreamsBuilderFactoryBeanConfigurer> customizerProvider, org.springframework.core.env.ConfigurableEnvironment environment)
KafkaStreamsRegistry	kafkaStreamsRegistry()
org.springframework.cloud.stream.binder.kafka.streams.KafkaStreamsStreamListenerSetupMethodOrchestrator	kafkaStreamsStreamListenerSetupMethodOrchestrator(org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties, KafkaStreamsExtendedBindingProperties kafkaStreamsExtendedBindingProperties, KeyValueSerdeResolver keyValueSerdeResolver, KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue, org.springframework.cloud.stream.binder.kafka.streams.KStreamStreamListenerParameterAdapter kafkaStreamListenerParameterAdapter, Collection<org.springframework.cloud.stream.binding.StreamListenerResultAdapter> streamListenerResultAdapters, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.core.CleanupConfig> cleanupConfig, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.config.StreamsBuilderFactoryBeanConfigurer> customizerProvider, org.springframework.core.env.ConfigurableEnvironment environment)
KeyValueSerdeResolver	keyValueSerdeResolver(Object streamConfigGlobalProperties, KafkaStreamsBinderConfigurationProperties properties)
org.springframework.cloud.stream.binder.kafka.streams.KStreamBoundElementFactory	kStreamBoundElementFactory(org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties, KafkaStreamsBindingInformationCatalogue KafkaStreamsBindingInformationCatalogue, EncodingDecodingBindAdviceHandler encodingDecodingBindAdviceHandler)
org.springframework.cloud.stream.binder.kafka.streams.KStreamStreamListenerParameterAdapter	kstreamStreamListenerParameterAdapter(KafkaStreamsMessageConversionDelegate kstreamBoundMessageConversionDelegate, KafkaStreamsBindingInformationCatalogue KafkaStreamsBindingInformationCatalogue)
org.springframework.cloud.stream.binder.kafka.streams.KStreamStreamListenerResultAdapter	kstreamStreamListenerResultAdapter()
org.springframework.cloud.stream.binder.kafka.streams.KTableBoundElementFactory	kTableBoundElementFactory(org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties, EncodingDecodingBindAdviceHandler encodingDecodingBindAdviceHandler, KafkaStreamsBindingInformationCatalogue KafkaStreamsBindingInformationCatalogue)
KafkaStreamsMessageConversionDelegate	messageConversionDelegate(org.springframework.messaging.converter.CompositeMessageConverter compositeMessageConverter, SendToDlqAndContinue sendToDlqAndContinue, KafkaStreamsBindingInformationCatalogue KafkaStreamsBindingInformationCatalogue, KafkaStreamsBinderConfigurationProperties binderConfigurationProperties)
MessageConverterDelegateSerde	messageConverterDelegateSerde(org.springframework.messaging.converter.CompositeMessageConverter compositeMessageConverterFactory)
SendToDlqAndContinue	sendToDlqAndContinue()
Map<String,Object>	streamConfigGlobalProperties(KafkaStreamsBinderConfigurationProperties configProperties, org.springframework.kafka.config.KafkaStreamsConfiguration kafkaStreamsConfiguration, org.springframework.core.env.ConfigurableEnvironment environment, SendToDlqAndContinue sendToDlqAndContinue)
StreamsBuilderFactoryManager	streamsBuilderFactoryManager(KafkaStreamsBindingInformationCatalogue catalogue, KafkaStreamsRegistry kafkaStreamsRegistry, KafkaStreamsBinderMetrics kafkaStreamsBinderMetrics, org.springframework.kafka.streams.KafkaStreamsMicrometerListener listener, org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaStreamsBinderSupportAutoConfiguration

public KafkaStreamsBinderSupportAutoConfiguration()

Method Details

binderConfigurationProperties

@Bean
@ConfigurationProperties(prefix="spring.cloud.stream.kafka.streams.binder")
public KafkaStreamsBinderConfigurationProperties binderConfigurationProperties(org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties,
 org.springframework.core.env.ConfigurableEnvironment environment,
 org.springframework.cloud.stream.config.BindingServiceProperties properties,
 org.springframework.context.ConfigurableApplicationContext context)
                                                                        throws Exception

Throws:

Exception

kafkaStreamsConfiguration

@Bean
public org.springframework.kafka.config.KafkaStreamsConfiguration kafkaStreamsConfiguration(@Qualifier("binderConfigurationProperties")
 KafkaStreamsBinderConfigurationProperties properties,
 org.springframework.core.env.Environment environment)

streamConfigGlobalProperties

@Bean("streamConfigGlobalProperties")
public Map<String,Object> streamConfigGlobalProperties(@Qualifier("binderConfigurationProperties")
 KafkaStreamsBinderConfigurationProperties configProperties,
 org.springframework.kafka.config.KafkaStreamsConfiguration kafkaStreamsConfiguration,
 org.springframework.core.env.ConfigurableEnvironment environment,
 SendToDlqAndContinue sendToDlqAndContinue)

kstreamStreamListenerResultAdapter

@Bean
public org.springframework.cloud.stream.binder.kafka.streams.KStreamStreamListenerResultAdapter kstreamStreamListenerResultAdapter()

kstreamStreamListenerParameterAdapter

@Bean
public org.springframework.cloud.stream.binder.kafka.streams.KStreamStreamListenerParameterAdapter kstreamStreamListenerParameterAdapter(KafkaStreamsMessageConversionDelegate kstreamBoundMessageConversionDelegate,
 KafkaStreamsBindingInformationCatalogue KafkaStreamsBindingInformationCatalogue)

kafkaStreamsStreamListenerSetupMethodOrchestrator

@Bean
public org.springframework.cloud.stream.binder.kafka.streams.KafkaStreamsStreamListenerSetupMethodOrchestrator kafkaStreamsStreamListenerSetupMethodOrchestrator(org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties,
 KafkaStreamsExtendedBindingProperties kafkaStreamsExtendedBindingProperties,
 KeyValueSerdeResolver keyValueSerdeResolver,
 KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue,
 org.springframework.cloud.stream.binder.kafka.streams.KStreamStreamListenerParameterAdapter kafkaStreamListenerParameterAdapter,
 Collection<org.springframework.cloud.stream.binding.StreamListenerResultAdapter> streamListenerResultAdapters,
 org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.core.CleanupConfig> cleanupConfig,
 org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.config.StreamsBuilderFactoryBeanConfigurer> customizerProvider,
 org.springframework.core.env.ConfigurableEnvironment environment)

messageConversionDelegate

@Bean
public KafkaStreamsMessageConversionDelegate messageConversionDelegate(@Qualifier("integrationArgumentResolverMessageConverter")
 org.springframework.messaging.converter.CompositeMessageConverter compositeMessageConverter,
 SendToDlqAndContinue sendToDlqAndContinue,
 KafkaStreamsBindingInformationCatalogue KafkaStreamsBindingInformationCatalogue,
 @Qualifier("binderConfigurationProperties")
 KafkaStreamsBinderConfigurationProperties binderConfigurationProperties)

messageConverterDelegateSerde

@Bean
public MessageConverterDelegateSerde messageConverterDelegateSerde(@Qualifier("integrationArgumentResolverMessageConverter")
 org.springframework.messaging.converter.CompositeMessageConverter compositeMessageConverterFactory)

compositeNonNativeSerde

@Bean
public CompositeNonNativeSerde compositeNonNativeSerde(@Qualifier("integrationArgumentResolverMessageConverter")
 org.springframework.messaging.converter.CompositeMessageConverter compositeMessageConverterFactory)

kStreamBoundElementFactory

@Bean
public org.springframework.cloud.stream.binder.kafka.streams.KStreamBoundElementFactory kStreamBoundElementFactory(org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties,
 KafkaStreamsBindingInformationCatalogue KafkaStreamsBindingInformationCatalogue,
 EncodingDecodingBindAdviceHandler encodingDecodingBindAdviceHandler)

kTableBoundElementFactory

@Bean
public org.springframework.cloud.stream.binder.kafka.streams.KTableBoundElementFactory kTableBoundElementFactory(org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties,
 EncodingDecodingBindAdviceHandler encodingDecodingBindAdviceHandler,
 KafkaStreamsBindingInformationCatalogue KafkaStreamsBindingInformationCatalogue)

globalKTableBoundElementFactory

@Bean
public GlobalKTableBoundElementFactory globalKTableBoundElementFactory(org.springframework.cloud.stream.config.BindingServiceProperties properties,
 EncodingDecodingBindAdviceHandler encodingDecodingBindAdviceHandler,
 KafkaStreamsBindingInformationCatalogue KafkaStreamsBindingInformationCatalogue)

sendToDlqAndContinue

@Bean
public SendToDlqAndContinue sendToDlqAndContinue()

kafkaStreamsBindingInformationCatalogue

@Bean
public KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue()

keyValueSerdeResolver

@Bean
@ConditionalOnMissingBean
public KeyValueSerdeResolver keyValueSerdeResolver(@Qualifier("streamConfigGlobalProperties")
 Object streamConfigGlobalProperties,
 @Qualifier("binderConfigurationProperties")
 KafkaStreamsBinderConfigurationProperties properties)

interactiveQueryServices

@Bean
public InteractiveQueryService interactiveQueryServices(KafkaStreamsRegistry kafkaStreamsRegistry,
 @Qualifier("binderConfigurationProperties")
 KafkaStreamsBinderConfigurationProperties properties)

kafkaStreamsRegistry

@Bean
public KafkaStreamsRegistry kafkaStreamsRegistry()

streamsBuilderFactoryManager

@Bean
public StreamsBuilderFactoryManager streamsBuilderFactoryManager(KafkaStreamsBindingInformationCatalogue catalogue,
 KafkaStreamsRegistry kafkaStreamsRegistry,
 @Nullable
 KafkaStreamsBinderMetrics kafkaStreamsBinderMetrics,
 @Nullable
 org.springframework.kafka.streams.KafkaStreamsMicrometerListener listener,
 org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties)

kafkaStreamsFunctionProcessor

@Bean
@Conditional(FunctionDetectorCondition.class)
public KafkaStreamsFunctionProcessor kafkaStreamsFunctionProcessor(org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties,
 KafkaStreamsExtendedBindingProperties kafkaStreamsExtendedBindingProperties,
 KeyValueSerdeResolver keyValueSerdeResolver,
 KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue,
 KafkaStreamsMessageConversionDelegate kafkaStreamsMessageConversionDelegate,
 org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.core.CleanupConfig> cleanupConfig,
 org.springframework.cloud.stream.function.StreamFunctionProperties streamFunctionProperties,
 @Qualifier("binderConfigurationProperties")
 KafkaStreamsBinderConfigurationProperties kafkaStreamsBinderConfigurationProperties,
 org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.config.StreamsBuilderFactoryBeanConfigurer> customizerProvider,
 org.springframework.core.env.ConfigurableEnvironment environment)

encodingDecodingBindAdviceHandler

@Bean
public EncodingDecodingBindAdviceHandler encodingDecodingBindAdviceHandler()