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.
|Modifier and Type||Method and Description|
This method is called upon just after stream creation and subscription.
This method is called when an exception occurs during stream processing.
stream- the just subscribed stream.
Copyright © 2013-2018–2019 SeedStack. All rights reserved.