В предыдущей статье автор рассказал про построение пайплайна Kafka-to-Kafka с промежуточным разделением потока и дедупликацией событий, а также, что такое состояние оператора и зачем оно нужно.
В этой статье добавим возможность динамического определения топика в Kafka для каждого события, куда его нужно записать.
⛓ Ссылка на статью
🔖 Предыдущая часть — КЛИК
➡️ Java Developer | #статья