первого топика и ждать его в финальном?
В это и смысл, не?
Угу, у меня просто по цепочке сообщение не долетает до финального топика, поэтому и решил спросить, может там есть какие то особенности
Значит надо разбить топологию на мелкие и тестировать отдельно. Например как тут Один тест для Movies, Один для Ratings, и один e2e https://github.com/gAmUssA/streaming-movie-ratings-min-0519/tree/master/src/test/java/io/confluent/demo
Спасибо)) будем смотреть
Idea отлично умеет дебажить стримы, если это Java
Котлин) пока не разобрался, спасибо за совет
Обсуждают сегодня