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 使用方法见压缩包内；或者直接执行，参数不全时会打印使用方法。

版本kafka_2.13-2.5.0. 官网下载太慢了,备份一下. 直接可以用 启动方法 方法一：加守护进程启动 bin/kafka-server-start.sh -daemon config/server.properties 方法二：通过后台来启动 nohup kafka-server-start.sh ../config/server.properties

CMAK就是Kafka Manager的前身,是一个Kafka集群管理工具，最早由雅虎开源，用户可以在Web界面执行集群管理操作。

基于Kafka的数据同步服务搭建，内容涵盖Kafka部署，Kafka安全配置，跨DC，数据加密，认证等诸多元素

logstash接收kafka插件，已经压缩成zip格式，可以直接集成到logstash

已经编译过的kafka-manager-2.0.0.2，解压后即可使用