Логика повторов DSL Kafka Streams (запись записи обратно в тему)

Question

При выполнении KStream - левое соединение с KTable, я хочу отправить запись обратно в ту же тему, если правая таблица не совпадает, через X секунд.

Это возможно с помощью DSL?

Answer 1

Полагаю, вы могли бы

KStream[] streams = stream.leftJoin(table,...).branch(...);
stream[1].transform(...).to("input-topic");

. Вы используете ветвь для помещения объединенных записей в первый поток и несвязанных записей во второй поток.Второй поток передается в transform(), который использует хранилище состояний для буферизации этих записей, и вы можете context.forward() отправлять их, используя punctuations с 5-секундной задержкой.