本文介绍使用kafka自带的zookeeper安装 kafka环境,在实际使用中基本上不会这样去进行配置,对于之前没有接触过的同学通过这样的配置可以对zookeeper和kafka有一个初步的认识。 特别注意: 最新版的Kafka 2.8.0,移除了对Zookeeper的依赖,通过KRaft进行自己的集群管理。前提条件 因为kafka是依赖于java环境运行的,所以需要在linux中安装java环境,请确保linux中安装了java环境准备工作下载kafka:kafka.apache.org/downloads 或者使用百度云: 链接:pan.baidu.com/s/11Mu5WVna… 提取码:pzpz上传至服务器后解压:tar -zxvf kafka_2.12-2.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命令:./bin/zookeeper-server-start.sh config/zookeeper.properties 后台运行: ./bin/kafka-server-start.sh -daemon config/server.properties 复制代码 启动 kafka 命令:./bin/kafka-server-start.sh -daemon config/server.properties 复制代码kafka常用命令创建topic : ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 查看 topic 列表: ./bin/kafka-topics.sh -list -zookeeper localhost:2181 创建生产者: ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 创建消费者: ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning 增加分区: .bin/kafka-topics.sh --zookeeper localhost:2181/kafka --alter --topic topic-config --partitions 3