У меня топология в сборке с использованием streamparse, она получает данные от kafka, а затем spout...