在使用Kafka3.4.0并且用Kraft(KafkaRaft)替代Zookeeper的情况下，步骤会有一些变化。这是因为Kraft模式下Kafka自身管理元数据，而不再依赖Zookeeper。以下是使用Kraft模式的Kafka3.4.0创建topic并进行生产和消费测试的具体步骤：###1.**启动Kaf

在kafka3.0之后，kafka正式推出了kraft模式，通过节点之间kraft共识保证Quorum机制，Leader节点的选举由具有投票权的Controller来决定。集群元数据信息都存在集群本身的topic里QuorumQuorum中一个节点可以处于一下四种状态（1）Candidate，可以主动发起投票（2）Leader，唯一，也是ActiveContr

1.集群规划hadoop02(192.168.58.130)hadoop03(192.168.58.131)hadoop04(192.168.58.132)kafkakafkakafka2.集群部署1.下载kafka二进制包https://kafka.apache.org/downloads2.解压mkdir/usr/kafkatar-zxvf/home/kafka_2.13-3.6.1.tgz-C/usr/kafka/3.

手动部署Kraft模式kafka集群基本信息IP地址HostnameReleaseKafka-Version172.29.145.157iamdemo1Centos7.9kafka_2.12-3.5.1172.29.145.182iamdemo2Centos7.9kafka_2.12-3.5.1172.29.145.183iamdemo3Centos7.9kafka_2.12-3.5.1下载安装包kafka安

Kafka集群版本：V3.5.1名称Node1Node2Node3IP172.29.145.157172.29.145.182172.29.145.183（1）查看Kraft集群中的状态以及Leader节点，投票节点使用--status可以查看集群选举次数/水位线以及投票节点等使用--replication可以查看Ledaer和Follower分布使用kafka-m

首先引入一些基础的定义:\(C:S_X\rightarrow\mathcal{D}^*\):thesourcecodeforar.v.\(X\),where\(S_X\)istherangeof\(X\),\(\mathcal{D}^*\)isthesetoffinite-lengthstringsofsymbolsfroma\(D\)-aryalphabet.WLOG,assumethat\(D