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

Class GlobalKTableBinderConfiguration

java.lang.Object

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

@Configuration
@Import({org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration.class,MultiBinderPropertiesConfiguration.class,KafkaStreamsBinderHealthIndicatorConfiguration.class,KafkaStreamsJaasConfiguration.class})
public class GlobalKTableBinderConfiguration
extends Object

Configuration for GlobalKTable binder.

Since:

2.1.0

Author:

Soby Chacko

Constructor Summary

Constructors

Constructor	Description
GlobalKTableBinderConfiguration()

Method Summary

Modifier and Type	Method	Description
GlobalKTableBinder	GlobalKTableBinder(KafkaStreamsBinderConfigurationProperties binderConfigurationProperties, KafkaTopicProvisioner kafkaTopicProvisioner, KafkaStreamsExtendedBindingProperties kafkaStreamsExtendedBindingProperties, KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue, Map<String,Object> streamConfigGlobalProperties, KafkaStreamsRegistry kafkaStreamsRegistry)
static org.springframework.beans.factory.config.BeanFactoryPostProcessor	outerContextBeanFactoryPostProcessor()
KafkaTopicProvisioner	provisioningProvider(KafkaStreamsBinderConfigurationProperties binderConfigurationProperties, org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties, org.springframework.beans.factory.ObjectProvider<AdminClientConfigCustomizer> adminClientConfigCustomizer)

Methods inherited from class java.lang.Object

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

Constructor Details

GlobalKTableBinderConfiguration

public GlobalKTableBinderConfiguration()

Method Details

provisioningProvider

@Bean
public KafkaTopicProvisioner provisioningProvider(KafkaStreamsBinderConfigurationProperties binderConfigurationProperties,
 org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties,
 org.springframework.beans.factory.ObjectProvider<AdminClientConfigCustomizer> adminClientConfigCustomizer)

GlobalKTableBinder

@Bean
public GlobalKTableBinder GlobalKTableBinder(KafkaStreamsBinderConfigurationProperties binderConfigurationProperties,
 KafkaTopicProvisioner kafkaTopicProvisioner,
 KafkaStreamsExtendedBindingProperties kafkaStreamsExtendedBindingProperties,
 KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue,
 @Qualifier("streamConfigGlobalProperties")
 Map<String,Object> streamConfigGlobalProperties,
 KafkaStreamsRegistry kafkaStreamsRegistry)

outerContextBeanFactoryPostProcessor

@Bean
@ConditionalOnBean(name="outerContext")
public static org.springframework.beans.factory.config.BeanFactoryPostProcessor outerContextBeanFactoryPostProcessor()