kafka可视化工具整理（七）
零、主流kafka可视化工具有两种①安装在本地的服务，通过网络连接kafka拉取数据并展示 比如：offsetexplorer 应用②安装在服务器上应用，通过服务器自行拉取代码，对外提供Web，查看kafka的状态及数据。比如：kafdrop应用一、本地服务 offsetexplorer1、去kaf
Kafka3.0 SASL安全认证
下面主要介绍Kafka两种认证方式kafka验证方式： SASL/PLAIN：不能动态添加用户配置文件写死账号密码 SASL/SCRAM： 可以动态的添加用户 SASL/PLAIN方式cd /usr/local/kafka/kafka_2.12-3.0.1/bin/## 复制一份sasl cp
Kafka：消费者参数配置
Kafka：消费者参数配置
Kafka的历史版本对应SpringBoot版本
截至目前（2023年），Kafka的最新版本是2.9.0，发布于2022年11月30日。Kafka的历史版本可以在Kafka官方网站的下载页面中找到。Kafka从0.8版本开始发布，经历了多个版本的迭代和升级。每个版本都有其自己的特点和改进，Kafka用户可以根据自己的需要选择合适的版本使用。
linux虚拟机搭建kafka（单节点、使用kafka自带zookeeper）
本文使用kafka单节点安装及配置，并使用kafka自带的zookeeper。一般kafka需要起三个kafka构成集群，可以连单独的zookeeper，本文不涉及。linux需要开启防火墙，否则可能出现外部连不上虚拟机的kafka的情况。修改kafka/bin/config下的zookeeper.
kafka常用命令大全
kafka命令大全
mq如何保证消息顺序性
刚才说到了一个topic可以有多个Partition，kafka确保每个Partition只能同一个group中的同一个Consumer消费，所以就Consumer来说，可以保证一个Partition的消息顺序消费，然后kafka的Producer端可以根据要发送消息内容，指定Partition K
Kafka重复消费以及消费线程安全关闭的解决方案
Kafka重复消费以及消费线程安全关闭的解决方案
Flume采集数据到Kafka操作详解
Flume采集数据到Kafka操作详解
Flink实现同时消费多个kafka topic，并输出到多个topic
flink同时消费多个kafka topic，并输出到多个topic
Kafka学习笔记
Kafka是一个分布式的流媒体平台（存储、计算）应用：消息系统、日志收集、用户行为追踪、流式处理（对数据流）高吞吐量：可以处理TB级的海量数据，因为消息持久化消息持久化：消息存在硬盘里，对硬盘顺序读写（性能高于对内存的随机读取）高可靠性：分布式的，可以集群部署，一台挂了还有别的高扩展性：一个集群，如
kafka tool下载安装和使用
kafka tool工具下载 安装 和使用
Kafka安装及启动用法详解
Kafka安装及启动用法详解
KafKa -相关参数优化
broker 处理消息的最大线程数，默认为 3，建议设为 cpu 核数 + 1：例如：cpu 核数 8 ：2. 处理磁盘 IO 的线程数broker 处理磁盘 IO 的线程数，建议设为 cpu 核数 x 2 ：例如：cpu 核数 8：3. 数据落盘策略Kafka重度依赖底层操作系统提供的功能。当上层
实战：Spring Cloud Stream集成兼容多消息中间件kafka、rabbitmq
Spring Cloud Stream集成多消息中间件kafka、rabbitmq较为简单，直接省去了原生中间的的操作与处理，开发人员可以直接任意切换和混用多种消息中间件，大大增加架构的可用性与可移植性。本实战案例提供重试、私信、手动ack、消费者分组和负载等高可用方案，直接可接入生产使用。
Kafka学习笔记
kafka
Flink反压如何排查
Flink反压如何排查，是我们在进行flink开发以及监控的流程中必不可少的一项技能，同时也是很多大厂面试需要问题的知识点。
云服务部署kafka 报错：“docker run“ requires at least 1 argument.
这里需要注意一下有一个小坑，如果你之前一直是部署在自己电脑的虚拟机上的最后-p的命令使用的是--net=host wurstmeister/kafka:2.12-2.3.1，创建容器指令：docker run -d --name zookeeper -p 2181:2181 zookeeper:3.
Kafka - 主题Topic与消费者消息Offset日志记录机制
kafka topic分区存储消息以及 消息信息存储的形式与日志记录
如何保证Mq消息不丢失
mq: rabbitmq, rocketmq, kafka
