Я новичок в Kafka, и я хотел бы знать, возможно ли и разумно ли реализовать то, что я планирую реализовать.
Предположим, у нас есть два источника, s1
и s2
, которые испускаютнекоторые сообщения по темам t1
и t2
соответственно.Теперь я хотел бы иметь приемник, который слушает обе темы, и я бы хотел, чтобы он обрабатывал кортежи сообщений <m1, m2>
где m1.key == m2.key
.
Если m1.key
никогда не было найдено в каком-либо сообщениииз s2
, то приемник полностью игнорирует m1.key
(никогда не будет обрабатывать его).
Таким образом, приемник будет работать только с ключами, над которыми работали s1
и s2
.
Некоторым традиционным и, возможно, наивным решением было бы иметь какой-то кеш или хранилище и работать с элементом, только когда оба сообщения находятся в кеше.
Я бы хотел знать, есть ли у Кафкипредлагает решение этой проблемы.