ключ uuid, у д==ругого ключ== null, а uuid в теле сообщенй.
dsl для джойна примерно такой
topicB
.map((k,v) -> v.rqUid)
.join(topicA)
Правильно ли я понимаю, что в теории может быть такая ситуация, что сообщения в топик, где нет ключа лягут в одни партиции, а с ключом в другие. И джойн работать не будет?
Делать rekeying в Kafka streams. Есть метод selectKey. Можно ещё на ksqlDB сделать https://kafka-tutorials.confluent.io/rekey-a-stream/ksql.html
Обсуждают сегодня