kafka的消息数据积压处理方案详解（两个方向）
通过架构图展示kafka的消息数据积压处理方案，两个原因，两个思路。
python中kafka的安装和使用教程
Kafka是一个分布式流处理系统，流处理系统使它可以像消息队列一样publish(发布)或者subscribe(订阅)消息，分布式提供了容错性，并发处理消息的机制。kafka运行在集群上，集群包含一个或多个服务器。kafka把消息存在topic中，每一条消息包含键值（key），值（value）和时间
尚硅谷YYDS (课件资料)
尚硅谷大数据技术之基于虚拟机 CDH5.12.1(Kerberos、Sentry 等)尚硅谷大数据项目之实时数仓项目 13 天(spark+clickhouse+es)尚硅谷大数据技术之 Structured Steaming。尚硅谷大数据技术之 Kubernetes、Zabbix。尚硅谷大数据技术
Kafka中那些巧妙的设计
Kafka是一个分布式、多分区、基于发布/订阅模式的消息队列，具有可扩展和高吞吐率的特点。
SpringBoot集成Kafka低版本和高版本
SpringBoot集成Kafka低版本和高版本，怎么学会选择自己的kafka版本。
SpringBoot集成Kafka
SpringBoot集成Kafka工程搭建SpringBoot集成Kafka配置SpringBoot集成Kafka生产消息SpringBoot集成Kafka消费消息
Kafka部署安装及简单使用
Console.WriteLine($"发送事件{dr.Value}到{dr.TopicPartitionOffset}成功");Console.WriteLine($"创建商品：Order:{value}");Console.WriteLine($"创建商品：Key:{key}");listene
Kafka可视化管理工具-CMAK（kafka-manager）
一、简介为了简化开发者和服务工程师维护Kafka集群的工作，yahoo构建了一个叫做Kafka管理器的基于Web工具，叫做 Kafka Manager（已改名为 cmak）。这个管理工具可以很容易地发现分布在集群中的哪些topic分布不均匀，或者是分区在整个集群分布不均匀的的情况。它支持管理多个集群
Kafka topic分区增加副本
Kafka中topic的每个分区可以设置多个副本。如果副本数为1，当该分区副本的leader节点宕机后，会导致该分区不可用。故需要设置多副本来保证可用性。实际项目中，存在项目初期创建了副本数为1的topic，但是后期又需要扩大副本数的场景。通常不能直接删除topic重建，可以通过如下操作实现。
go kafka 配置SASL认证及实现SASL PLAIN认证功能
配置SASL认证及实现SASL PLAIN认证功能
Spring boot集成kafka(windows)
Spring boot集成kafka(windows)
SpringBoot集成Kafka消息队列（JSON序列化和反序列化对象）
1.说明上文SpringBoot集成Kafka消息队列介绍了SpringBoot集成Kafka的方法，其生产者和消费者的发送和接收的是字符串，本文介绍使用JSON序列化和反序列化对象的方法，即生产者发送一个对象的实例，消费者能够接收到一个对象的实例。2.引入依赖在 pom.xml 中引入Spring
简单总结：Flink和Kafka是如何做到精准一致性的
flink kafka保证精准一致性
kafka | 1.docker部署kafka
docker部署kafka
Kafka在K8S中启动时间慢问题
1、通过调整 num.recovery.threads.per.data.dir 进行集群恢复，最大速度取决于磁盘的速度。2、在没有特殊情况下，尽量正常关闭Kafka集群。直接关闭主机等非正常关闭，可能需要重新加载所有数据文件。3、可以通过增加 宽限时间terminationGracePeriodS
windows下安装kafka总结
windows下安装kafka总结
kafka基础
kafka基础
Kafka在Mac下的安装与使用
kafka在Mac下的安装与使用，比如启动、关闭。如果zookeeper关闭，但kafka没有关闭，zookeeper的子进程就没有关闭。
Flume监听多个文件目录，并根据文件名称不同，输出到kafka不同topic中
监听多数据源目录，并根据文件名称不一样，输出到kafka不同topic中
MQ如何保证消息不丢失
就比如Producer生产一个消费发送到了A节点，这个时间集群中各个节点是不同步消息的，Consumer却在B节点上消费这条消息，这个时候才会把A节点的消息同步到B节点来 再进行消费。会造成消费时消息丢失才场景是：Consumer消费消息变为异步的方式，刚开始收到需要消费的消息就往MQ发送一个消息，
