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

Reply via email to