В чём проблема того, что вы вызываете REST прямо из Kafka consumer?