CentOS7中新版本自带zookeeper搭建Kafka集群
所有的broker在启动的时候都会往zookeeper进行注册，目的就是选举出一个controller，controlller会读取注册上的从点的数据（通过监听机制），生成集群的元数据信息，之后把这些信息都分发给其他的服务器，让其他服务器能感知到集群中其他成员的存在。它是一个分布式协调框架。在典型的
使用javaApi监控 kafka 集群的环境下消费组的积压信息
javaApi 监控 kafka 集群的环境下消费组的积压信息
Flink预加载分区维表，实时更新维表配置信息
总体来讲，关联维表有三个基础的方式：实时数据库查找关联（Per-Record Reference Data Lookup）、预加载维表关联（Pre-Loading of Reference Data）和维表变更日志关联（Reference Data Change Stream），而根据实现上的优化可
【SpringBoot】在Springboot中怎么设置Kafka自动创建Topic
【代码】【SpringBoot】在Springboot中怎么设置Kafka自动创建Topic。
flink1.17.0 集成kafka，并且计算
这里只是做了一个简单的消费kafka的flink例子，消费成功后还可以通过sink发送出去，还可以用transform进行转换，这里后面再演示，如果不对的可以指出。
Apache Kafka - 跨集群数据镜像 MirrorMaker
在分布式系统中，数据镜像是一项重要的功能，它可以将数据从一个集群复制到另一个集群，以保证数据的高可用性和容错性。Apache Kafka是一个流处理平台，它提供了一种跨集群数据镜像的解决方案，可以让用户轻松地将数据从一个Kafka集群复制到另一个Kafka集群。Kafka跨集群数据镜像的实现方式是通
Flume实现Kafka数据持久化存储到HDFS
本文关键字：Flume、Kafka、HDFS、实时数据、存储。对于一些实时产生的数据，除了做实时计算以外，一般还需要归档保存，用于离线数据分析。使用Flume的配置可以实现对数据的处理，并按一定的时间频率存储，本例中将从Kafka中按天存储数据到HDFS的不同文件夹。
Docker环境 运行Kafka容器失败
Docker环境 运行Kafka容器失败
kafka消费多个topic的使用
我们在业务中难免遇到一个kafka消费多个topic的消息，本文帮助大家如何在业务中用一个类消费多个topic消息。
【kafka】服务器命令行查询kafka信息消费情况
kafka-tool出问题的情况下，可以用命令行来查看kafka信息
kafka查看topic和消息内容命令
【代码】kafka查看topic和消息内容命令。
kafka如何保证消息不被重复消费
（1）kafka有个offset的概念，当每个消息被写进去后，都有一个offset，代表他的序号，然后consumer消费该数据之后，隔一段时间，会把自己消费过的消息的offset提交一下，代表我已经消费过了。下次我要是重启，就会继续从上次消费到的offset来继续消费。但是当我们直接kill进程了
Kafka消息队列中关于消息的实现原理
一个业务Topic中保存了100条消息数据，消费者1从Topic中消费消息数据，同时会定期将消费数据的偏移量写入到kafka内部的Consumer_offset主题上，如果消费者1在消费到第50条消息数据时，异常宕机不可用，此时消费者2启动后，就可以通过消费者1写入到Consumer_offset主
Springboot配置kafka用户名密码
SpringBoot配置kafka用户名密码
Docker 安装Kafka
第一步：查看本地镜像、检索Kafka镜像和下载Kafka 镜像# 查看本地镜像docker images# 检索Kafka镜像docker search kafka# 下载Kafka 镜像指定版本docker pull wurstmeister/kafka:latest第二步：启动Zookeeper
Kafka消息队列实现消息的发送和接收
消息生产者Producer产生消息数据，发送到Kafka消息队列中，一台Kafka节点只有一个Broker，消息会存储在Kafka的Topic（主题中），不同类型的消息数据会存储在不同的Topic中，可以利用Topic实现消息的分类，消息消费者Consumer会订阅消息存储的Topic，从Topic
kafka删除topic
1. 首先需要在config/server.properties中添加 delete.topic.enable=true 属性。2. 用topic list找到想要删除的topic名称。
Kafka3.3.1最新版安装教程（无需zookeeper）
kafka最新版3.3.1安装教程
spring boot配置双Kafka方法
关于spring boot整合Kafka实现双Kafka配置
Kafka三节点集群搭建
可以看到集群中zookeeper-1节点是Follower角色，zookeeper-2节点是Leader角色，zookeeper-3节点是Follower角色，正就验证了我们起那么说的那句话，当ServerID大并且投票超过半数则当选Leader节点，zookeeper-2节点启动后，ServerI
