Re: Issue with GlobalKTable on sink topic

2018-05-18 Thread Daniele Tria
; You mean, you stop the application and restart it? This should not be > required. How long did you run the application in the first run? During > the first run, can you confirm that the app write date into the > GlobalKTable topic (I want to understand if the write or read path is > t

Re: Issue with GlobalKTable on sink topic

2018-05-17 Thread Daniele Tria
obalKTable consumes the specified topic to the current > end-offsets to pre-populate itself before any other processing starts. > > > -Matthias > > On 5/16/18 6:30 AM, Daniele Tria wrote: > > Dear community, I'm struggling with an issue regarding `GlobalKTable`: >

Issue with GlobalKTable on sink topic

2018-05-16 Thread Daniele Tria
Dear community, I'm struggling with an issue regarding `GlobalKTable`: that is demanded to read from a topic A, where I add key-mapped records from another stream. This topic A is populated within the same application by ` stream.to` costruct with some events that I need to manipulate before they c