com.github.aidensuen.cloud.stream

Class AbstractKafkaStreamConsumer<K,V>

java.lang.Object

com.github.aidensuen.cloud.stream.AbstractKafkaStreamConsumer<K,V>

@EnableBinding(value=org.springframework.cloud.stream.binder.kafka.streams.annotations.KafkaStreamsProcessor.class)
public abstract class AbstractKafkaStreamConsumer<K,V>
extends Object

Constructor Summary

Constructors

Constructor and Description
AbstractKafkaStreamConsumer()

Method Summary

Modifier and Type	Method and Description
abstract void	doProcess(org.apache.kafka.streams.kstream.KStream<K,V> kStream)
void	process(org.apache.kafka.streams.kstream.KStream<K,V> kStream)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractKafkaStreamConsumer

public AbstractKafkaStreamConsumer()

Method Detail

process

@StreamListener(value="input")
 @SendTo(value="output")
public void process(org.apache.kafka.streams.kstream.KStream<K,V> kStream)

doProcess

public abstract void doProcess(org.apache.kafka.streams.kstream.KStream<K,V> kStream)