Flume是Cloudera提供的一个高可用的，高可靠的，分布式的海量日志采集、聚合和传输的系统。Flume基于流式架构，灵活简单。

面向字节_Kafka.pdf

ELK7.5+KAFKA超详细安装文档和资源包

ansible-kafka-管理员 一个低级的ansible库，用于管理Kafka配置。 它不使用Kafka脚本，而是直接连接到Kafka和Zookeeper（如果需要）以确保创建资源。 无需SSH连接到远程主机。 如果您想增加分区，复制因子，更改主题的参数或轻松管理ACL，则此库非常适合您。 要求 该库使用 ， 和库。 使用pip安装它们： pip install -r requirements.txt 请仅使用那些版本，因为某些更新可能会破坏该库。 目前，该库与0.11.0及更高版本中的Kafka兼容。 它可以与在PLAINTEXT，SASL_PLAINTEXT，SSL和SASL_SSL中配置的Kafka一起使用。 关于Zookeeper ，它还与Kerberos身份验证不兼容，仅与SSL，SASL和DIGEST身份验证兼容。 安装 在您的剧本的requirements.yml中添加以下要求： --- # from GitHub, overriding the name and specifying a specific tag - src : https://gi

超级安全银行 该存储库以银行为例，展示了如何在.NET Core中实现事件源，CQRS和DDD。 该代码已作为示例，与上的几篇文章同时出现： ASP.NET Core API用作所有面向客户端的操作的入口点： 建立客户 创建账户 存钱 取钱 基础设施 该系统使用和托管在Azure上。 也提供“本地”版本，该版本使用 跟踪所有事件 卡夫卡播出整合活动 MongoDb存储API使用的QueryModel 只需通过从根文件夹运行docker-compose up即可启动内部部署基础架构。 给个星星！ :white_medium_star: 你喜欢这个项目吗？ 给它一个星星，叉子，给我一

SlimMessageBus SlimMessageBus是.NET消息代理的客户端外观。 它带有针对特定代理（Apache Kafka，Azure EventHub，MQTT / Mosquitto，Redis发布/订阅）的实现以及内存中消息传递（进程内通信）的实现。 SlimMessageBus还提供了对消息队列的请求-响应实现。 科 建立状态 主 发展 其他 SlimMessageBus的关键元素 消费者： IConsumer -发布者/订阅者中的订阅者（或队列使用者） IRequestHandler -请求-响应中的请求处理程序 制片人： IPublishBus发布者/ IPublishBus发布者（或队列生产者） IRequestResponseBus -req / resp中的发件人 IMessageBus扩展IPublishBus和IRequestResponseBus 其他： IRequestMessage -请求消息的标记 MessageBus当前上下文

Apache Kafka Documentation 官网文档 官网文档 官网文档 官网文档 官网文档

使用Kafka的小伙伴，有没有为无法直观地查看 Kafka 的 Topic 里的内容而发过愁呢？ 此版本为window64位，安装简单快捷

kafka streams 实战 。

使用环境:Jdk 1.8 使用场景：生产环境海量数据，用kafka-console-consumer 消费kafka某时间段消息用于分析问题，生产环境海量数据，用kafka-console-consumer.sh只能消费全量，文件巨大，无法grep。 代码来源于博主：BillowX_ ，感谢分享 原贴地址：https://blog.csdn.net/weixin_35852328/article/details/105511784 使用方法见压缩包内；或者直接执行，参数不全时会打印使用方法。