Uses of Class
org.springframework.cloud.stream.binder.kafka.streams.KafkaStreamsRegistry
Packages that use KafkaStreamsRegistry
Package
Description
-
Uses of KafkaStreamsRegistry in org.springframework.cloud.stream.binder.kafka.streams
Methods in org.springframework.cloud.stream.binder.kafka.streams that return KafkaStreamsRegistryModifier and TypeMethodDescriptionKafkaStreamsBinderSupportAutoConfiguration.kafkaStreamsRegistry()Methods in org.springframework.cloud.stream.binder.kafka.streams with parameters of type KafkaStreamsRegistryModifier and TypeMethodDescriptionGlobalKTableBinderConfiguration.GlobalKTableBinder(KafkaStreamsBinderConfigurationProperties binderConfigurationProperties, KafkaTopicProvisioner kafkaTopicProvisioner, KafkaStreamsExtendedBindingProperties kafkaStreamsExtendedBindingProperties, KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue, Map<String, Object> streamConfigGlobalProperties, KafkaStreamsRegistry kafkaStreamsRegistry) KafkaStreamsBinderSupportAutoConfiguration.interactiveQueryServices(KafkaStreamsRegistry kafkaStreamsRegistry, KafkaStreamsBinderConfigurationProperties properties) org.springframework.cloud.stream.binder.kafka.streams.KStreamBinderKStreamBinderConfiguration.kStreamBinder(KafkaStreamsBinderConfigurationProperties binderConfigurationProperties, KafkaTopicProvisioner kafkaTopicProvisioner, KafkaStreamsMessageConversionDelegate KafkaStreamsMessageConversionDelegate, KafkaStreamsBindingInformationCatalogue KafkaStreamsBindingInformationCatalogue, KeyValueSerdeResolver keyValueSerdeResolver, KafkaStreamsExtendedBindingProperties kafkaStreamsExtendedBindingProperties, KafkaStreamsRegistry kafkaStreamsRegistry) org.springframework.cloud.stream.binder.kafka.streams.KTableBinderKTableBinderConfiguration.kTableBinder(KafkaStreamsBinderConfigurationProperties binderConfigurationProperties, KafkaTopicProvisioner kafkaTopicProvisioner, KafkaStreamsExtendedBindingProperties kafkaStreamsExtendedBindingProperties, KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue, Map<String, Object> streamConfigGlobalProperties, KafkaStreamsRegistry kafkaStreamsRegistry) KafkaStreamsBinderSupportAutoConfiguration.streamsBuilderFactoryManager(KafkaStreamsBindingInformationCatalogue catalogue, KafkaStreamsRegistry kafkaStreamsRegistry, KafkaStreamsBinderMetrics kafkaStreamsBinderMetrics, org.springframework.kafka.streams.KafkaStreamsMicrometerListener listener, org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties) Method parameters in org.springframework.cloud.stream.binder.kafka.streams with type arguments of type KafkaStreamsRegistryModifier and TypeMethodDescriptionKafkaStreamsBinderHealthIndicatorConfiguration.kafkaStreamsBinderHealthIndicator(org.springframework.beans.factory.ObjectProvider<KafkaStreamsRegistry> kafkaStreamsRegistry, KafkaStreamsBinderConfigurationProperties kafkaStreamsBinderConfigurationProperties, org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties, KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue) Constructors in org.springframework.cloud.stream.binder.kafka.streams with parameters of type KafkaStreamsRegistryModifierConstructorDescriptionGlobalKTableBinder(KafkaStreamsBinderConfigurationProperties binderConfigurationProperties, KafkaTopicProvisioner kafkaTopicProvisioner, KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue, KafkaStreamsRegistry kafkaStreamsRegistry) InteractiveQueryService(KafkaStreamsRegistry kafkaStreamsRegistry, KafkaStreamsBinderConfigurationProperties binderConfigurationProperties) Constructor for InteractiveQueryService. -
Uses of KafkaStreamsRegistry in org.springframework.cloud.stream.binder.kafka.streams.endpoint
Methods in org.springframework.cloud.stream.binder.kafka.streams.endpoint with parameters of type KafkaStreamsRegistryModifier and TypeMethodDescriptionKafkaStreamsTopologyEndpointAutoConfiguration.topologyEndpoint(KafkaStreamsRegistry kafkaStreamsRegistry) Constructors in org.springframework.cloud.stream.binder.kafka.streams.endpoint with parameters of type KafkaStreamsRegistryModifierConstructorDescriptionKafkaStreamsTopologyEndpoint(KafkaStreamsRegistry kafkaStreamsRegistry)