Kafka架构原理(超级详细)
许多消息队列所采用的"插入-获取-删除"范式中，在把一个消息从队列中删除之前，需要你的处理系统明确的指出该消息已经被处理完毕，从而确保你的数据被安全的保存直到你使用完毕。（1）每一个分区都是多个分段构成，每个LogSegment分段，包括了'一个'数据文件和'一个'索引文件, 它们的文件名都是以某一
【黑马头条之热点文章kafkaStream】
Kafka Stream是Apache Kafka从0.10版本引入的一个新Feature。它是提供了对存储于Kafka内的数据进行流式处理和分析的功能。Kafka Stream的特点如下：Kafka Stream提供了一个非常简单而轻量的Library，它可以非常方便地嵌入任意Java应用中，也可
kafka启用SASL认证后使用kafka-consumer-groups.sh查看消费组报错的问题
/bin/kafka-consumer-groups.sh --describe --bootstrap-server kafka的IP:kafka的端口--command-config config/consumer-group-ssl.properties --group test-group
kafka复习：（22）一个分区只能被消费者组中的一个消费者消费吗？
默认情况下，一个分区只能被消费者组中的一个消费者消费。但可以自定义PartitionAssignor来打破这个限制。分别运行生产者和消费者，可以看到相同消费者组里两个消费者可以消费study2023这个topic的同一个分区的数据。二、定义两个消费者，给其配置上述PartitionAssignor.
大数据面试题：Kafka怎么保证数据不丢失，不重复？
大数据面试题：Kafka怎么保证数据不丢失，不重复？
Kafka-配置Kerberos安全认证(JDK8、JDK11)
从 Kerberos 服务器上拷贝到目标机器 或 找运维人员要一份。从 Kerberos 服务器上拷贝到目标机器 或 找运维人员要一份。3、Kerberos 配置文件（2、keytab 文件（1、JAAS 配置文件。
Kafka 整合 SpringBoot
编写测试代码：ApplicationTests.java。
Kafka、RocketMQ、RabbitMQ如何保证消息的顺序消费？
全局有序是一个topic下的所有消息都要保证顺序，如果要保证消息全局顺序消费，可以将该主题的队列数设置为1，牺牲高可用性。局部有序是指保证同一个消息队列上的消息顺序消费。RabbitMQ没有属性设置消息的顺序性，所以在没有前提的情况下说 RabbitMQ消息的消费具有顺序性是错误的。二、生产者在发送
Kafka概述
Kafka的概述，包括基本架构，可靠性，幂等性等特征描述
【Kafka】【十七】消费者poll消息的细节与消费者心跳配置
默认情况下，消费者⼀次会poll500条消息。代码中设置了⻓轮询的时间是1000毫秒。
Middleware ❀ Kafka功能与使用详解
Kafka是Apache基金会开发的一个开源流处理平台，由Scala和Java编写，Kafka是一个开源的分布式事件流平台，主要应用于大数据实时处理领域。
【新星计划】Kafka分布式发布订阅消息系统
Producer是消息的生产者，通常情况下，数据消息源可是服务器日志、业务数据及Web服务数据等，生产者采用推送的方式将数据消息发布到Kafka的主题中，主题本质就是一个目录，而主题是由Partition Logs（分区日志）组成，每条消息都被追加到分区中。与点对点消息系统不同的是，消费者可以订阅一
KafKa 3.x（三、Eagle、Kraft、压测调优，源码解析）
Kafka-Eagle框架用于监控Kafka集群运行状况。官网https://kafka-eagle.org。
一百零八、Kettle采集Kafka数据到HDFS（踩坑，亲测有效）
Kettle采集Kafka数据到HDFS
kafka详解
kafka是一款分布式、支持分区的、多副本，基于zookeeper协调的分布式消息系统。最大的特性就是可以实时处理大量数据来满足需求。
docker如何搭建Kafka
Kafka是一个分布式流处理平台，用于高吞吐量、低延迟的数据传输和处理。一般是用做分布式系统的消息中间件。
Kafka跨集群备份解决方案MirrorMaker
从本质上说，MirrorMaker 就是一个消费者 + 生产者的程序。消费者负责从源集群（Source Cluster）消费数据，生产者负责向目标集群（Target Cluster）发送消息。整个镜像流程如下图所kafka跨集群备份解决方案MirrorMaker示：MirrorMaker 连接的源集
kafka入门，节点服役和退役（新增节点和删除节点）(十二)
kafka入门，节点服役和退役（新增节点和删除节点）。
kafka-3-kafka应用的核心要点和内外网访问
kafka应用的核心要点和内外网访问
SpringBoot——集成Kafka详解
我们知道，kafka中每个topic被划分为多个分区，那么生产者将消息发送到topic时，具体追加到哪个分区呢？这就是所谓的分区策略，Kafka 为我们提供了默认的分区策略，同时它也支持自定义分区策略。若发送消息时指定了分区（即自定义分区策略），则直接将消息append到指定分区；若发送消息时未指定
