波塞冬:卡夫卡0.8的客户 源码

未维护 该项目目前未维护。 还有其他一些与Ruby中的Kafka进行交互的选项: 兼容0.9的纯Ruby客户端支持消费者群体。 REST代理, 。 对于JRuby,有封装了Java使用者。 波塞冬 波塞冬(Poseidon)是Kafka的客户。 波塞冬仅支持0.8 API及更高版本。 在1.0.0之前,应将其视为ALPHA软件,而不是必须进行生产准备。 用法 API文档 在本地安装Kafka代理 按照Kafka Wiki上的来构建Kafka 0.8并启动并运行测试代理。 向Kafka发送消息 require 'poseidon' producer = Poseidon :: Producer . new ( [ "localhost:9092" ] , "my_test_producer" ) messages = [ ] messages << Poseidon :: Mes