Thanks Luca This is exactly what I was looking for.
On a related note let's say I stop and restart my application. What would I have to do so that the I do not re process events? I am still working through the kstreams 101 tutorial. I have not gotten to the DSL tutorials yet Andy On 5/30/22, 11:16 PM, "Luca" <c...@lucapette.me> wrote: Hi Andy, If I understand your problem correctly, you want a "foreach" terminal operation. You can check out the API here: https://kafka.apache.org/32/documentation/streams/developer-guide/dsl-api.html Luca On Tue, May 31, 2022, at 6:37 AM, Andy wrote: > All the Kstream examples I have found demonstrate how to use map, filter, > and join on streams. The last step they typically user to() to > publish/produce the results to a new stream > > How can I get the data out of the stream? For example I need to send the > data to a legacy data that can not use kafka. Or maybe I want to plot the > data,… > > I looked at the java doc and did not find anything > > Any idea what I should “google” to to find a code example? > > Kind regards > > Andy > lucapette.me