Hello Pradeep,
If you just want to close the Streams app based on the first observation of
a specific value, you can consider using a shutdown latch, in which the
`transformValues()` will decrement and the main thread starting the streams
will listen on, and once the latch has been decremented
Hi,
I am trying to call kafka stream close based on the presence of a value in
the output of ValueTransformer.ValueTransformer produces a
List
Is there a way to avoid the foreach on Kstream and try to get the
first value alone? (like streams api method findFirst)
private void
