Как передать данные в Kafka из Ruby, используя режим синхронизации с ack=1 или ack=all
Мы пытаемся отправить данные в Kafka в режиме синхронизации, но не знаем, как этого добиться.
Afaik, есть две основные библиотеки Ruby Kafka и .
ruby-kafkaэто реализация ruby, которая отлично работает, но не поддерживает более новые версии Kafka,
rdkafka-rubyэто реализация C, но, по словам сопровождающих, она поддерживает только асинхронное производство ,
Наш текущий план состоит в том, чтобы передать данные в Redis, а затем отправить их в Kafka с помощью библиотеки Python или коннектора Kafka, но я чувствую, что должен быть лучший способ.
Что мне не хватает? Может ли кто-нибудь предоставить исходный код о том, как синхронно нажать на Kafka?