public class KStreamBuilderFactoryBean
extends org.springframework.beans.factory.config.AbstractFactoryBean<org.apache.kafka.streams.kstream.KStreamBuilder>
implements org.springframework.context.SmartLifecycle
AbstractFactoryBean for the KStreamBuilder instance
and lifecycle control for the internal KafkaStreams instance.| Constructor and Description |
|---|
KStreamBuilderFactoryBean(java.util.Map<java.lang.String,java.lang.Object> streamsConfig) |
KStreamBuilderFactoryBean(org.apache.kafka.streams.StreamsConfig streamsConfig) |
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.kafka.streams.kstream.KStreamBuilder |
createInstance() |
org.apache.kafka.streams.KafkaStreams |
getKafkaStreams()
Get a managed by this
KStreamBuilderFactoryBean KafkaStreams instance. |
java.lang.Class<?> |
getObjectType() |
int |
getPhase() |
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
setAutoStartup(boolean autoStartup) |
void |
setClientSupplier(org.apache.kafka.streams.KafkaClientSupplier clientSupplier) |
void |
setPhase(int phase) |
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
public KStreamBuilderFactoryBean(org.apache.kafka.streams.StreamsConfig streamsConfig)
public KStreamBuilderFactoryBean(java.util.Map<java.lang.String,java.lang.Object> streamsConfig)
public void setClientSupplier(org.apache.kafka.streams.KafkaClientSupplier clientSupplier)
public java.lang.Class<?> getObjectType()
getObjectType in interface org.springframework.beans.factory.FactoryBean<org.apache.kafka.streams.kstream.KStreamBuilder>getObjectType in class org.springframework.beans.factory.config.AbstractFactoryBean<org.apache.kafka.streams.kstream.KStreamBuilder>protected org.apache.kafka.streams.kstream.KStreamBuilder createInstance()
throws java.lang.Exception
createInstance in class org.springframework.beans.factory.config.AbstractFactoryBean<org.apache.kafka.streams.kstream.KStreamBuilder>java.lang.Exceptionpublic void setAutoStartup(boolean autoStartup)
public void setPhase(int phase)
public boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecyclepublic void stop(java.lang.Runnable callback)
stop in interface org.springframework.context.SmartLifecyclepublic void start()
start in interface org.springframework.context.Lifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclepublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecyclepublic int getPhase()
getPhase in interface org.springframework.context.Phasedpublic org.apache.kafka.streams.KafkaStreams getKafkaStreams()
KStreamBuilderFactoryBean KafkaStreams instance.KStreamBuilderFactoryBean hasn't been started.