本文介绍使用kafka自带的zookeeper安装kafka环境,在实际使用中基本上不会这样去进行配置,对于之前没有接触过的同学通过这样的配置可以对zookeeper和kafka有一个初步的认识。 特别注意:最新版的Kafka2。8。0,移除了对Zookeeper的依赖,通过KRaft进行自己的集群管理。前提条件 因为kafka是依赖于java环境运行的,所以需要在linux中安装java环境,请确保linux中安装了java环境准备工作下载kafka:kafka。apache。orgdownloads 或者使用百度云: 链接:pan。baidu。coms11Mu5WVna 提取码:pzpz上传至服务器后解压:tarzxvfkafka2。122。8。0。tgz复制代码首先配置kafka自带的zookeeper 第一步、修改config下zookeeper。properties 注意:其中dataDir是快照存放地址,clientPort是客户端连接zookeeper服务的端口 第二步、修改config目录下的server。properties,修改log。dirs和zookeeper。connect。log。dirs是日志存放文件夹,zookeeper。connect是zookeeper连接地址(端口和clientPort保持一致)。 第三步、至此,kafka单机版环境已搭建完毕。(如果对里面的参数没修改的话,可不修改,直接用默认的,但是需要记录一下默认配置的端口后续用的到,一般zookeeper默认端口为2181)启动zookeeper和kafka 注意:启动时所在的路径问题,需要kafka根目录下,因为要加载config中配置文件,在根目录下会比较方便些,还要注意端口是否被占用 启动zookeeper(启动kafka自带的zookeeper(加上daemon,可以让这个进程挂在后台进行,否则会发现是个阻塞进程,只能再开一个终端进行其他操作) 启动zookeeper命令:。binzookeeperserverstart。shconfigzookeeper。properties后台运行:。binkafkaserverstart。shdaemonconfigserver。properties复制代码 启动kafka命令:。binkafkaserverstart。shdaemonconfigserver。properties复制代码kafka常用命令创建topic: 。binkafkatopics。shcreatezookeeperlocalhost:2181replicationfactor1partitions1topictest 查看topic列表: 。binkafkatopics。shlistzookeeperlocalhost:2181 创建生产者: 。binkafkaconsoleproducer。shbrokerlistlocalhost:9092topictest 创建消费者: 。binkafkaconsoleconsumer。shbootstrapserverlocalhost:9092topictestfrombeginning 增加分区: 。binkafkatopics。shzookeeperlocalhost:2181kafkaaltertopictopicconfigpartitions3