日志=》kafka》ELK
一般工作方式为c/s架构，client端安装在需要收集日志的主机上，server端负责将收到的各节点日志进行过滤、修改等操作在一并发往elasticsearch上去。它的特点有：分布式，零配置，自动发现，索引自动分片，索引副本机制，restful风格接口，多数据源，自动搜索负载等。也是一个开源和免费
深入解析Kafka的offset管理
但是无法做到真正的负载均衡，因为实际系统中的每个生产者产生的消息量及每个Broker的消息存储量都是不一样的，如果有些生产者产生的消息远多于其他生产者的话，那么会导致不同的Broker接收到的消息总数差异巨大，同时，生产者也无法实时感知到Broker的新增和删除。在众多leader的转移过程中，就会
最简单的SpringCloudStream集成Kafka教程
SpringCloudStream是一个构建高扩展性的事件消息驱动的微服务框架。简单点说就是帮助你操作MQ，可以与底层MQ框架解耦。将来想要替换MQ框架的时候会比较容易。Kafka是一个分布式发布 - 订阅消息系统，源于LinkedIn的一个项目，2011年成为开源Apache项目。ZooKeepe
k8s 中部署kafka集群
k8s 部署kafka集群
【Springboot】微服务学习笔记十：微服务项目整合Kafka实现文章上下架功能
主要介绍了Springboot集成Kafka及快速掌握消息的发送及接收，然后利用该功能实现文章的上下架功能。
[docker-compose中间件集群系列] - 4 kafka的作用、原理以及集群搭建
kafka的作用、原理以及集群搭建
Python 操作 Kafka --- kafka-python
kafka-python：https://github.com/dpkp/kafka-python kafka-python 文档：https://kafka-python.readthedocs.io/en/master/apidoc/modules.html kafka 官方文档：http
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保证精准一致性
