У меня есть топология, которая выполняет два соединения kstream, проблема, с которой я сталкиваюсь, заключается в попытке выполнить модульное тестирование с TopologyTestDriver, отправив пару ConsumerRecords с pipeInput, а затем readOutput. Кажется, не работает.
Я думаю, это может быть из-за того, что объединения используют внутреннюю базу данных rockdb в реальной кафке, которую мы не используем в тестах.
Так что я искал решение для этого, но не могу найти какое-либо.
Примечание. Этот метод тестирования прекрасно работает при удалении соединений kstream-kstream.