文件名称：waterdrop:WaterDrop 是一个独立的 Karafka 组件库，用于生成 Kafka 消息
文件大小：48KB
文件格式：ZIP
更新时间：2024-08-24 05:15:43
rubygems rubygem kafka apache-kafka karafka-framework
水滴 注意：此处提供的文档是指 WaterDrop 2.0.0 。 WaterDrop 2.0不能与 Karafka 1.* ，它的目标是作为 Karafka 1.*生态系统之外的独立生产者工作，或者作为尚未发布的 Karafka 2.0.* 。 有关 WaterDrop 1.*用法的详细信息，请参阅分支及其文档。 Gem 过去使用额外的验证层以简单的方式向 Kafka 发送消息。 它是生态系统的一部分。 它： 线程安全吗 支持同步制作 支持异步生产 支持缓冲 支持向多个集群生产消息 支持多种交付策略 适用于 Kafka 1.0+ 和 Ruby 2.5+ 目录 使用 WaterDrop 根据应用逻辑缓冲消息 使用 WaterDrop 和 rdkafka 缓冲区来实现定期自动刷新 仪表 使用统计 分叉和潜在的内存问题 参考 投稿说明 安装 gem install waterdr
【文件预览】：
waterdrop-master
----.gitignore(1007B)
----README.md(12KB)
----CHANGELOG.md(5KB)
----.github()
--------workflows()
--------FUNDING.yml(25B)
----certs()
--------mensfeld.pem(1KB)
----Gemfile(217B)
----log()
--------.gitkeep(0B)
----docker-compose.yml(427B)
----.ruby-version(6B)
----LICENSE(7KB)
----waterdrop.gemspec(1KB)
----.rspec(22B)
----Gemfile.lock(3KB)
----config()
--------errors.yml(225B)
----spec()
--------support()
--------lib()
--------spec_helper.rb(852B)
----.diffend.yml(158B)
----.ruby-gemset(10B)
----lib()
--------water_drop()
--------waterdrop.rb(96B)
--------water_drop.rb(617B)
----.coditsu()
--------ci.yml(138B)