WaterDrop:Kafka 消息生產 Ruby 庫

資料工具

WaterDrop 是一個獨立的 Ruby gem,用於輕鬆發送消息到 Apache Kafka,支持同步、異步、事務等多種生產模式。

此 GitHub 開源專案 WaterDrop 是 Karafka 生態系統中的一個獨立 Ruby 庫,專門用於生產 Kafka 消息。根據 README 說明,它提供了一個額外的驗證層,確保消息的可靠傳輸。主要功能包括線程安全、支持同步和異步生產、事務處理、緩衝機制、多集群支持、多種交付策略以及每主題的配置變體。WaterDrop 兼容異步 gem 生態系統,並要求 Kafka 1.0+ 和 Ruby 3.2+ 以上版本。專案適用於在 Ruby 應用中集成數據流處理,例如構建實時數據管道或自動化工作流程,幫助開發者高效地與 Kafka 交互。

Stars286
Forks41
語言Ruby
分類資料工具
標籤
apache-kafkarubykafka-producerdata-streamingkarafka
GitHub Topics
apache-kafkaapache-kafka-producerkafkakarafkakarafka-applicationkarafka-frameworkrubyruby-kafkarubygemrubygemswaterdrop