windows下安装部署kafka集群

一、下载

下载后解压缩文件如下：

二、配置

在这之前需先部署的 zookeeper 集群

前提：已部署 zookeeper 集群(server.1,server.2,server.3);

1、在 server.1(IP1) 上配置 kafka_2.13-2.6.0configserver.properties 文件

broker.id=1
advertised.listeners=PLAINTEXT://IP1(localhost):9092
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
log.dirs=./logs
num.partitions=2
num.recovery.threads.per.data.dir=1
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=3
log.retention.hours=168
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
zookeeper.connect=IP1(localhost):2181,IP2:2181,IP3:2181
zookeeper.connection.timeout.ms=18000
group.initial.rebalance.delay.ms=0

server.2,server.3 与以上步骤一致：不同的点是将 (1.) broker.id 改为 唯一值； (2.) advertised.listeners 改为当前服务器 IP 、端口可不变

三、启动kafka

1、启动

在kafka 目录中 执行命令

.inwindowskafka-server-start.bat .configserver.properties

2、创建主题

在开一个cmd ,执行 命令

.inwindowskafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

3、查看主题

.inwindowskafka-topics.bat --list --zookeeper localhost:2181

4、查看主题详细信息

.inwindowskafka-topics.bat --describe --zookeeper localhost:2181

5、创建生产者

在开一个 cmd，执行命令

.inwindowskafka-console-producer.bat --broker-list localhost:9092 --topic test --producer.config .configproducer.properties

6、创建消费者

.inwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning --consumer.config .configconsumer.properties