Re: A question about kafka streams API

2018-09-12 Thread Yui Yoi
hip between them, and the later, > good, message might get processed. > > Does that help? > -John > > On Wed, Sep 12, 2018 at 8:38 AM Adam Bellemare > wrote: > > > Hi Yui Yoi > > > > > > Keep in mind that Kafka Consumers don't traditionally reques

Re: A question about kafka streams API

2018-09-12 Thread Yui Yoi
Hi Adam, Thanks a lot for the rapid response, it did helped! Let me though ask one more simple question: Can I make a stream application stuck on an invalid message? and not consuming any further messages? Thanks again On Wed, Sep 12, 2018 at 2:35 PM Adam Bellemare wrote: > Hi Yui

A question about kafka streams API

2018-09-12 Thread Yui Yoi
TL;DR: my streams application skips uncommitted messages Hello, I'm using streams API via spring framework and experiencing a weird behavior which I would like to get an explanation to: First of all: The attached zip is my test project, I used kafka cli to run a localhost broker and zookeeper wha