Kafka 审计系统 Chaperone

Apache
Java Scala 查看源码»
跨平台
Uber
2017-01-06
凝小紫

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

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

Chaperone 由几个部分组成:

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

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

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

的码云指数为
超过 的项目
加载中

评论(2)

JackFace
JackFace
研究一下的
_Leo_
_Leo_
谁能解释下 这个能做什么吗?

暂无资讯

暂无问答

Kafka or RabbitMQ:消息中间件选型深入分析

一、前言 消息队列中间件(简称消息中间件)是指利用高效可靠的消息传递机制进行与平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型,它可以在分...

04/15 17:33
2
0
消息中间件Kafka与RabbitMQ谁更胜一筹?

在 IM 这种讲究高并发、高消息吞吐的互联网场景下,MQ 消息中间件是个很重要的基础设施,它在 IM 系统的服务端架构中担当消息中转、消息削峰、消息交换异步化等角色。 当然,MQ 消息中间件的...

02/25 17:06
26
0

没有更多内容

加载失败,请刷新页面

没有更多内容

返回顶部
顶部