У меня есть топология, которая вычисляет количество раз, когда определенный IP-адрес замечен, и это само по себе прекрасно работает.Сейчас я пытаюсь добавить исключения, то есть не учитывать этот IP-адрес.
На данный момент эта топология представляет собой KStream сообщений (назовем его IP-потоком), содержащих данные + IP-адрес и добавление сообщений.в этот поток обновляются значения, как и ожидалось.
Теперь мне нужно добавить исключения, которые происходят из другой темы, и эти исключения редко меняются, несколько раз в месяц.
Идея состоит в том, чтобы прочитатьИз темы исключения преобразуйте его в KTable, затем я оставил присоединение IP-потока к KTable, чтобы исключить IP-адреса, найденные в IP-потоке.(Пока не уверен, что это работает)
Мой процесс (топология) работает, и когда я добавляю IP-адрес для исключения в KTable, я вижу в StateStore, созданном левым соединением KStream с KTable,IP я добавил в KTable, но пересчет IP не происходит.
Начальные значения уже вычислены, и я хотел бы пересчитать их, когда произойдет изменение в KTable, возможно ли это?Я ожидал, что изменение перезапустит вычисления.