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

Class KafkaStreamsRegistry

java.lang.Object

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

public class KafkaStreamsRegistry
extends Object

An internal registry for holding KafkaStreams objects maintained through StreamsBuilderFactoryManager.

Author:

Soby Chacko

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsRegistry()

Method Summary

Modifier and Type	Method	Description
org.springframework.kafka.config.StreamsBuilderFactoryBean	streamsBuilderFactoryBean(String applicationId)
List<org.springframework.kafka.config.StreamsBuilderFactoryBean>	streamsBuilderFactoryBeans()

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaStreamsRegistry

public KafkaStreamsRegistry()

Method Details

streamsBuilderFactoryBean

public org.springframework.kafka.config.StreamsBuilderFactoryBean streamsBuilderFactoryBean(String applicationId)

streamsBuilderFactoryBeans

public List<org.springframework.kafka.config.StreamsBuilderFactoryBean> streamsBuilderFactoryBeans()