Как реализовать паттерн request-reply на Kafka?