KStreamBuilderFactoryBean (Spring Kafka 1.2.2.RELEASE API)

java.lang.Object
- org.springframework.beans.factory.config.AbstractFactoryBean<org.apache.kafka.streams.kstream.KStreamBuilder>
- - org.springframework.kafka.core.KStreamBuilderFactoryBean

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<org.apache.kafka.streams.kstream.KStreamBuilder>, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle
```
public class KStreamBuilderFactoryBean
extends org.springframework.beans.factory.config.AbstractFactoryBean<org.apache.kafka.streams.kstream.KStreamBuilder>
implements org.springframework.context.SmartLifecycle
```
An AbstractFactoryBean for the KStreamBuilder instance and lifecycle control for the internal KafkaStreams instance.

Since:

1.1.4

Author:

Artem Bilan, Ivan Ursul

Field Summary
- Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
  logger

Constructor Summary

Constructors
Constructor and Description
`KStreamBuilderFactoryBean(java.util.Map<java.lang.String,java.lang.Object> streamsConfig)`
`KStreamBuilderFactoryBean(org.apache.kafka.streams.StreamsConfig streamsConfig)`

Method Summary

All Methods Instance Methods Concrete Methods
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`	`setStateListener(org.apache.kafka.streams.KafkaStreams.StateListener stateListener)`
`void`	`setUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler exceptionHandler)`
`void`	`start()`
`void`	`stop()`
`void`	`stop(java.lang.Runnable callback)`

Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
afterPropertiesSet, destroy, destroyInstance, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - KStreamBuilderFactoryBean
```
public KStreamBuilderFactoryBean(org.apache.kafka.streams.StreamsConfig streamsConfig)
```
  - KStreamBuilderFactoryBean
```
public KStreamBuilderFactoryBean(java.util.Map<java.lang.String,java.lang.Object> streamsConfig)
```
- Method Detail
  - setClientSupplier
```
public void setClientSupplier(org.apache.kafka.streams.KafkaClientSupplier clientSupplier)
```
  - setStateListener
```
public void setStateListener(org.apache.kafka.streams.KafkaStreams.StateListener stateListener)
```
  - setUncaughtExceptionHandler
```
public void setUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler exceptionHandler)
```
  - getObjectType
```
public java.lang.Class<?> getObjectType()
```
    Specified by:
    
    getObjectType in interface org.springframework.beans.factory.FactoryBean<org.apache.kafka.streams.kstream.KStreamBuilder>
    
    Specified by:
    
    getObjectType in class org.springframework.beans.factory.config.AbstractFactoryBean<org.apache.kafka.streams.kstream.KStreamBuilder>
  - createInstance
```
protected org.apache.kafka.streams.kstream.KStreamBuilder createInstance()
                                                                  throws java.lang.Exception
```
    Specified by:
    
    createInstance in class org.springframework.beans.factory.config.AbstractFactoryBean<org.apache.kafka.streams.kstream.KStreamBuilder>
    
    Throws:
    
    java.lang.Exception
  - setAutoStartup
```
public void setAutoStartup(boolean autoStartup)
```
  - setPhase
```
public void setPhase(int phase)
```
  - isAutoStartup
```
public boolean isAutoStartup()
```
    Specified by:
    
    isAutoStartup in interface org.springframework.context.SmartLifecycle
  - stop
```
public void stop(java.lang.Runnable callback)
```
    Specified by:
    
    stop in interface org.springframework.context.SmartLifecycle
  - start
```
public void start()
```
    Specified by:
    
    start in interface org.springframework.context.Lifecycle
  - stop
```
public void stop()
```
    Specified by:
    
    stop in interface org.springframework.context.Lifecycle
  - isRunning
```
public boolean isRunning()
```
    Specified by:
    
    isRunning in interface org.springframework.context.Lifecycle
  - getPhase
```
public int getPhase()
```
    Specified by:
    
    getPhase in interface org.springframework.context.Phased
  - getKafkaStreams
```
public org.apache.kafka.streams.KafkaStreams getKafkaStreams()
```
    Get a managed by this KStreamBuilderFactoryBean KafkaStreams instance.
    
    Returns:
    
    KafkaStreams managed instance; may be null if this KStreamBuilderFactoryBean hasn't been started.
    
    Since:
    
    1.1.4

Class KStreamBuilderFactoryBean

Field Summary

Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

Constructor Summary

Method Summary

Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

Methods inherited from class java.lang.Object

Constructor Detail

KStreamBuilderFactoryBean

KStreamBuilderFactoryBean

Method Detail

setClientSupplier

setStateListener

setUncaughtExceptionHandler

getObjectType

createInstance

setAutoStartup

setPhase

isAutoStartup

stop

start

stop

isRunning

getPhase

getKafkaStreams