zookeeper+kafka消息队列集群部署
zookeeper是一种分布式协调技术，所谓分布式协调技术主要是用来解决分布式环境当中多个进程之间的同步控制，让它们有序的去访问某个共享资源，防止造成资源竞争（脑裂）的后果。
EIK+Filebeat+Kafka
Kafka 是一个分布式的基于发布/订阅模式的消息队列（MQ，Message Queue），主要应用于大数据领域的实时计算以及日志收集。
Kafka 与 Zookeeper 的关系
Apache Kafka 是一个高性能、分布式的消息队列系统，广泛用于实时数据流处理。而 Apache Zookeeper 是一个开源的分布式协调服务，提供了分布式应用程序的集中式服务。Kafka 和 Zookeeper 之间有着紧密的关系，Zookeeper 为 Kafka 提供了多种关键功能，使
Kafka之日志存储详解
kafka的日志存储保证的消息的可靠性，日志文件的存储方式及读写方式让kafka更加的高性能。
Kafka知识总结（消费者+重平衡）
意思就是前面两个当同组内有新的消费者加入或者旧的消费者退出的时候，会从新开始决定消费者消费方式，但是Sticky在同组中有新的消费者加入或者旧的消费者退出时，不会直接开始重构分配策略，而是保留现有消费者消费策略，将退出的消费者所消费的分区平均分配给现有消费者，新增消费者同理，同其他现存消费者的消费策
zookeeper+kafka消息队列群集部署
许多消息队列所采用的"插入-获取-删除"范式中，在把一个消息从队列中删除之前，需要你的处理系统明确的指出该消息已经被处理完毕，从而确保你的数据被安全的保存直到你使用完毕。例如，在电商系统中，用户下单后，订单处理的消息可以先放入消息队列，后续的库存更新、物流通知等操作可以异步进行，而不必等待每个环节依
使用flume将消息导入Kafka
版本使用:flume190,kafka200,hadoop260在flume文件目录创建ngcf目录,创建flume配置文件text.conf//：指定source的类型为spooldir，即监控指定目录中新出现的文件，并将这些文件的内容作为事件（events）来处理。//source监控的目录//
7.kafka中的消费语义、幂等性
kafka中的消费语义、幂等性
连接远程的kafka【linux】
连接远程的kafka【linux】
Kafka抛弃Zookeeper后如何启动？
Kafka在之前的版本中，如果没有ZooKeeper,Kafka将无法运行。 Kafka在在发布的2.8版本里，让用户可在完全不需要ZooKeeper的情况下运行Kafka。
Kafka 和 RabbitMQ用哪个？一篇文章告诉你他们的区别
可以看到，如果我们要做消息队列选型，有两件事是必须要做好的：列出业务最重要的几个特点深入到消息队列的细节中去比较等我们对这些中间件的特点非常熟悉之后，甚至可以把业务分解成不同的子业务，再根据不同的子业务的特征，引入不同的消息队列，即消息队列混用。这样，我们就可能会最大化我们的获益，最小化我们的成本。
消息队列选型之 Kafka vs RabbitMQ
消息队列即 Message+Queue，消息可以说是一个数据传输单位，它包含了创建时间、通道/主题信息、输入参数等全部数据；队列（Queue）是一种 FIFO（先进先出）的数据结构，编程语言一般都内置(内存中的)队列实现，可以作为进程间通讯（IPC）的方法。使用队列最常见的场景就是生产者/消费者模式
Kafka概念初识
前置知识 消息队列MQ。
AutoMQ vs Kafka: 来自小红书的独立深度评测与对比
Apache Kafka 分区迁移需要将分区的副本拷贝到新的节点，拷贝历史数据的同时还要追赶新写入的数据，迁移的耗时 = 分区数据量 / （迁移吞吐限制 - 分区写入吞吐），在实际生产环境中，分区迁移往往是小时级的，本测试中的 30 GiB 的分区迁移耗时就到了 15 分钟。除了迁移耗时长以外，Ap
Kafka的Consumers：高效数据消费的关键角色
Consumers（消费者）定义：Kafka Consumers 是读取和处理 Kafka 消息的客户端应用程序。消费者从一个或多个主题（Topic）中读取消息，并进行相应的数据处理。作用：消费者负责从 Kafka 集群中获取消息，进行业务逻辑处理，如数据分析、日志处理、事件驱动等。
使用Kafka实现带消息记录的实时传输对话场景（聊天室）
使用**Websocket**可以实现客户端的双向通信，客户端可以向服务端发送数据，服务端也可以向客户端发送数据。传输内容是可以实时传输了，但是如果没有存储功能，一刷新页面（或者重新进入）就再也看不到之前发送的消息，这是一个很大的麻烦。策略一数据持久化首先想到在传输的时候，顺带将数据存入数据库，貌似
kafka源码阅读-ReplicaManager解析
Kafka源码包含多个模块，每个模块负责不同的功能。服务端源码：实现Kafka Broker的核心功能，包括日志存储、控制器、协调器、元数据管理及状态机管理、延迟机制、消费者组管理、高并发网络架构模型实现等。Java客户端源码：实现了Producer和Consumer与Broker的交互机制，以及通
浅析Kafka Streams消息流式处理流程及原理
结合案例：统计消息中单词出现个数来测试并说明kafka-stream消息流式处理的执行流程
万字详解Kafka并附带go操作Kafka
本文一文讲懂Kafka基本原理以及操作Kafka的简单步骤
# Kafka_深入探秘者（10）：kafka 监控
# Kafka_深入探秘者（10）：kafka 监控第10章 01-JMX 第10章 02-编程获取指标 第10章 03-监控指标了解
