全部项目分类
我要评价
Apache
Java Scala 查看源码»
跨平台
Uber
分享
收藏
57 人收藏
收录时间:2017-01-06
Chaperone 详细介绍

作为 Kafka 审计系统,Chaperone 监控数据流的完整性和延迟。审计指标持久存储在数据库中,供 Kafka 用户量化其主题的损失。

Chaperone 的目标是在数据流经数据管道的每个阶段,能够抓住每个消息,统计一定时间段内的数据量,并尽早准确地检测出数据的丢失、延迟和重复情况。

Chaperone 由几个部分组成:

  • ChaperoneClient是一个库,可以像 Kafka 生产者或消费者一样审计邮件。 审计统计被发送到专用的 Kafka 主题,例如'chaperone-audit'。

  • ChaperoneCollector 使用'chaperone-audit' 的审计统计信息,并将其保存到数据库中。

  • ChaperoneService 审计保存在 Kafka 中的消息。 由于它是基于 uReplicator 构建的,它由两个子系统组成:ChaperoneServiceController,用于自动检测 Kafka 中的主题,并将主题分区分配给工作人员进行审计; ChaperoneServiceWorker 从指定的主题分区审核消息。 特别地,ChaperoneService 和 ChaperoneCollector 一起确保每个消息被审核一次。


大家对 Chaperone 的评论 (全部 2 条评论)
{{repayCom.userName}}
JackFace
研究一下的
cocky_
谁能解释下
这个能做什么吗?
顶部