直接安装
-
直接按照下载的版本是3.6.1,需要zookeeper。
-
解压D:/kafka
-
在这个目录下新建data目录,以后数据就放在这里。
-
配置zookeeper
修改
D:/kafka/config/zookeeper.properties
改成
dataDir=D:/kafka/data/zookeeper
- 启动zookeeper
cd D:/kafka/bin/windows
执行命令
zookeeper-server-start.bat ../../config/zookeeper.properties
- 配置kafka
修改
D:/kafka/config/server.properties
改成
log.dirs=D:/kafka/data/kafka
- 启动kafka
cd D:/kafka/bin/windows
执行命令
kafka-server-start.bat ../../config/server.properties
docker安装
services:
broker:
image: apache/kafka:latest
network_mode: "host"
container_name: broker
environment:
KAFKA_NODE_ID: 1
KAFKA_PROCESS_ROLES: broker,controller
KAFKA_LISTENERS: PLAINTEXT://localhost:9092,CONTROLLER://localhost:9093
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092
KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
KAFKA_CONTROLLER_QUORUM_VOTERS: 1@localhost:9093
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
KAFKA_NUM_PARTITIONS: 3
docker-compose up -d