Я закончил приложение с несколькими топологиями, эти топологии связаны друг с другом своим источником и приемником.
, например,
topology1 -> topology2 -> topology3
с помощью 'kafka-streams-test-utils', модульное тестирование с каждой топологией легко, но я понятия не имею, что делать с интеграциейтестовое задание.
Существует ли структура или пример для интеграционного теста со всеми топологиями?
UPDATE:
Я решил это, соединив все топологии через through