Skip to main content

Re: Newbie how to get key/value pojo out of a stream?

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" <ciao@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

Comments