org.seedstack.kafka

Interface StreamBuilder<K,V>

public interface StreamBuilder<K,V>

Implement this interface to build a Kafka stream topology. By annotating the implementing class with KafkaListener, the stream will be automatically subscribed to the specified topics.

The underlying Kafka stream client will be automatically started and stopped with the application. A unhandled failure will gracefully stop the stream and a later attempt will be rescheduled.

Method Summary

Modifier and Type	Method and Description
void	buildStream(org.apache.kafka.streams.kstream.KStream<K,V> stream) This method is called upon just after stream creation and subscription.
default void	onException(Exception e) This method is called when an exception occurs during stream processing.

Method Detail

buildStream

void buildStream(org.apache.kafka.streams.kstream.KStream<K,V> stream)

This method is called upon just after stream creation and subscription. It allows to define the specific topology of the stream.

Parameters:

stream - the just subscribed stream.

onException

default void onException(Exception e)
                  throws Exception

This method is called when an exception occurs during stream processing.

Parameters:

e - the exception that occurred.

Throws:

Exception - rethrow an exception to trigger a graceful stop and a retry after the specified delay.