kafka的docker镜像包含了kafka，zookeeper 和kafkamanager，可以通过docker 来load 安装

作为 Kafka 审计系统，Chaperone 监控数据流的完整性和延迟。审计指标持久存储在数据库中，供 Kafka 用户量化其主题的损失。Chaperone 的目标是在数据流经数据管道的每个阶段，能够抓住每个消息，统计一定时间段内的数据量，并尽早准确地检测出数据的丢失、延迟和重复情况。Chaperone 由几个部分组成：ChaperoneClient是一个库，可以像 Kafka 生产者或消费者一样审计邮件。 审计统计被发送到专用的 Kafka 主题，例如'chaperone-audit'。ChaperoneCollector 使用'chaperone-audit' 的审计统计信息，并将其保存到数据库中。ChaperoneService 审计保存在 Kafka 中的消息。 由于它是基于 uReplicator 构建的，它由两个子系统组成：ChaperoneServiceController，用于自动检测 Kafka 中的主题，并将主题分区分配给工作人员进行审计; ChaperoneServiceWorker 从指定的主题分区审核消息。 特别地，ChaperoneService 和 ChaperoneCollector 一起确保每个消息被审核一次。

KafkaNetCore ASP.NET Core 5.0和KAFKA 实施的技术： ASP.NET Core 5.0 卡夫卡 实体框架核心5.0 招摇UI

车流量监控 前言 目的1.对业务场景抽象，熟练的Spark编码2.增加自定义累加器，自定义UDF 3.Spark优化方式 项目数据处理架构 模块介绍 卡扣流量分析Spark Core 卡扣车流量转化率Spark Core 各区域车流量最高top5的道路统计SparkSQL 稽查布控，道路实时拥堵统计SparkStreaming 蜂巢表 monitor_flow_action表–日期日期天– monitor_id卡口号– camera_id摄像头编号–汽车车牌– action_time某个摄像头拍摄时间s –速度通过卡扣的速度– road_id道路id – area_id区域ID monito

取kafka入ElasticSearch完整工程代码，修改配置后，打成JAR包可直接运行。 1.kafka操作 2.Elasticsearch操作。 3.DB操作。 4.日志操作。

最新版windows kafka_2.13-2.4.1.zip

1、kafka-docker-compose集群安装 2、kafka配置详解

kafka 生成消费dome,可正常生产与消费

本实例使用 Flink 的有状态流处理和滑动窗口，实现实时点击量排行榜。 该实例统计过去 1 分钟内，点击量最高的男女用户各 10 名及其具体的点击数，同时每隔 1 秒（实时）更新统计结果，等到排行榜数据并将结果同步到 kafka 中。

调试kafka，一个生产者（通过postman调用可生产数据），一个消费者（自动消费）