Не могли бы вы дать мне совет относительно подхода к следующей проблеме.У меня есть две темы, одна со статическим контентом, а вторая с потоком данных.Задача состоит в том, чтобы объединить данные, что было бы легко в обычном случае.Я читал бы статический контент как GlobalKTable, а динамический контент как KStream и просто присоединялся к ним.Проблема в том, что данные поиска существуют в нескольких версиях в одной и той же теме.«Версии» идентифицируются полем «validFrom».Таким образом, данные потока должны быть объединены с данными поиска соответствующей версии в соответствии с их отметкой времени.Есть ли способ отфильтровать данные в GlobalKTable?
С уважением, Мартин