AW: Table updates are not consistent when doing a join with a Stream

Hi, I'm definitly no expert, but to me it sounds as not all your messages are getting processed by the same consumer. Are you using the key `foo` for partitioning? Is `baz` actually another key or is this mixup in your example and `baz` is another value with key `foo`? Hope you find a solution

Registration open for Community Over Code North America

Hello! Registration is still open for the upcoming Community Over Code NA event in Halifax, NS! We invite you to register for the event https://communityovercode.org/registration/ Apache Committers, note that you have a special discounted rate for the conference at US$250. To take advantage of th

Consumer group offset translation in Mirror Maker 2

Hi, We're using Mirror Maker 2 for replicating messages from our primary to secondary cluster, it's one way replication. We're also replicating by the consumer group offsets by adding the below properties sync.group.offsets.enabled=true sync.group.offsets.interval.seconds=5 emit.checkpoints.interv