Могут ли kafka-streams прослушивать две темы и ждать другого события, соответствующего идентификатору, и, как только он получит, отправить его в другую тему?

Question

У меня есть две разные темы кафки, в которых есть одинаковый идентификатор поля. Может ли поток прослушивать эти две темы и писать новое сообщение для третьей темы, когда он получает одинаковый идентификатор для обеих этих тем?

Answer 1

Возможно, вы сможете выполнить оконное соединение. Возможно, это поможет:https://kafka.apache.org/10/documentation/streams/developer-guide/dsl-api

Для соединений поток-поток важно подчеркнуть, что новая входная запись на одной стороне будет создавать выход соединения для каждой совпадающей записи на другой стороне, и в данном окне соединения может быть несколько таких совпадающих записей.