我正在处理的项目的当前流程涉及使用ruby-kafka gem推送到本地kafka。现在,需要为remote kafka添加生产者,并在其中也复制消息。而且我正在寻找一种更好的方法,而不是两次调用Kafka.new(...) ...您能帮我吗,您碰巧有什么想法吗?
ruby-kafka
remote kafka
Kafka.new(...)
免责声明:我为Confluent工作。