【文件属性】：
文件名称：Hermann:将librdkafka库包装为C扩展的Ruby gem
文件大小：27KB
文件格式：ZIP
更新时间：2021-05-03 04:34:33
C
赫尔曼
一个实现Kafka Publisher和Consumer的Ruby gem
该项目现在由Lookout Mobile Security拥有。 请参考他们的项目。
该库包装了用C语言实现的。必须先安装此库，然后才能使用Hermann gem。
用法
用法以为模型，非常简单。
支持Kafka 0.8。
Ruby 1.8.7和Ruby 2.1.1已经过测试，但是JRuby和版本只要安装了librdkafka库，= 1.8就可以工作。
这是该宝石的早期Alpha版本，因此请耐心等待。
注意：当前实现需要进行工作以确保线程安全。
消费者和生产者现在都对Kafka状态拥有自己的参考，应该能够很好地共存。
消费者的经纪人列表和分区规范现在也正在运行。 生产者将检测主题中的分区数，并将其消息随机分布在该分区集上。
消费者当前不记得他们的“最后一条消息”，也没有协调消费者群体内的分
【文件预览】：
Hermann-master
----ext()
--------hermann()
--------.ruby-version(11B)
----LICENSE.md(1KB)
----bin()
--------hermann(48B)
----spec()
--------producer_spec.rb(4KB)
--------consumer_spec.rb(825B)
--------hermann_lib()
--------spec_helper.rb(731B)
--------hermann_spec.rb(86B)
--------result_spec.rb(2KB)
--------fixtures()
--------timeout_spec.rb(811B)
----scripts()
--------.DS_Store(6KB)
--------produce_1_msg_localhost.rb(272B)
--------produce_1M_msgs_localhost.rb(316B)
--------send-one-big-message(461B)
--------produce_msgs_1min_localhost.rb(327B)
--------consume_msgs_loop_localhost.rb(312B)
--------produce_1_binary_msg_localhost.rb(256B)
----README.md(2KB)
----hermann.gemspec(889B)
----lib()
--------hermann()
--------hermann.rb(19B)
----Gemfile(179B)
----Rakefile(535B)
----test()
--------test_hermann.rb(143B)
----Gemfile.lock(848B)