Я создаю интеграционный тест для нашей системы kafka, используя Spring Встроенный брокер Kafka с MockSchemaRegistryClient. Я создаю тест для одной из наших топологий Stream, построенный с использованием Streams API (KStreamBuilder). В этой...

Я иду за знанием тайн. Во-первых, у меня есть две пары тем, одна тема в каждой паре связана с другой темой. Последние темы формируют две KTable, которые используются в KTable+KTable leftJoin. Проблема в том, что leftJoin создает ТРИ записи, когда...