Re: join not working in relation to how StreamsBuilder builds the topology

2020-08-11 Thread John Roesler
Hi Mathieu, Aaah, that is a bummer. The littlest things can be the hardest to find. Well, I'm glad I was able to help in some capacity. Cheers, -John On Tue, 2020-08-11 at 16:02 +0200, Mathieu D wrote: > Hi John, > > Thanks for your answer. > > Reading your suggestions forced me to reconsider

Re: join not working in relation to how StreamsBuilder builds the topology

2020-08-11 Thread Mathieu D
Hi John, Thanks for your answer. Reading your suggestions forced me to reconsider one more time the partitioner set on inputs. I already challenged all of them .. except one input that was provided in my test infrastructure by kafkacat. And it appears kafkacat is not using by default the same

Re: join not working in relation to how StreamsBuilder builds the topology

2020-08-10 Thread John Roesler
Hi Mathieu, That sounds frustrating. I’m sorry for the trouble. >From what you described, it does sound like something wacky is going on with >the partitioning. In particular, the fact that both joins work when you set >everything to 1 partition. You mentioned that you’re using the default

join not working in relation to how StreamsBuilder builds the topology

2020-08-10 Thread Mathieu D
Dear community, I have a quite tough problem I struggle to diagnose and fix. I'm not sure if it's a bug in Kafka-streams or some subtlety I didn't get in using the DSL api. The problem is the following. We have a quite elaborate stream app, working well, in production. We'd like to add a left