holodoz

Для такого используется Kafka Streams, два потока джойнятся по ключу, можно записывать результат в третий поток или отправлять в БД. Вот описание краткое, чтобы было понятно, куда копать:
https://kafka-school.ru/blogs/kafka-stream-unit/