Вот ситуация
1) скажем, модуль должен читать сообщения из topi c
2 Kafka, затем на основе записей и данных Redis модуль должен либо решите создать и отправить сообщение в Kafka И / ИЛИ обновить данные Redis
Мой вопрос: есть ли готовый к использованию модуль, поддерживающий весь вышеописанный процесс (например, слив слива Redis), или я должен написать этот модуль? сам?
Заранее спасибо,