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

2022-05-30 Thread Luca
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

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

2022-05-31 Thread Luca
streams comes with a handy reset tool. You can read about it here: https://kafka.apache.org/32/documentation/streams/developer-guide/app-reset-tool.html Luca On Tue, May 31, 2022, at 5:17 PM, andrew davidson wrote: > Thanks Luca > > This is exactly what I was looking for. > > On

Re: multiple consumers for a same topic in multiple copies

2016-10-31 Thread Luca Pertile
able to commit their offset in kafka independently as they move along the topic. Luca On 31 Oct 2016 16:42, "Patrick Viet" wrote: > Hi, > > I've done some searching and can't find much on this topic. > Here is what I'm looking at: > > So a usual usage o

Order of consumed messages in the same partition.

2014-11-12 Thread Filippo De Luca
application, and wondering if it a possibility, or is a bug in our codebase. Thanks for any helps. -- *Filippo De Luca* - WWW: http://filippodeluca.com IM: filosgang...@gmail.com