阅读量:0
docker安装kafka(KRaft 模式)
KRaft模式不再对Zookeeper依赖。
docker run -d --name kafka-kraft \ -p 9092:9092 -p 9093:9093 \ -e KAFKA_PROCESS_ROLES=broker,controller \ -e KAFKA_NODE_ID=1 \ -e KAFKA_CONTROLLER_QUORUM_VOTERS=1@127.0.0.1:9093 \ -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093 \ -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://47.103.16.200:9092 \ -e KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,CONTROLLER:PLAINTEXT \ -e KAFKA_INTER_BROKER_LISTENER_NAME=PLAINTEXT \ -e KAFKA_CONTROLLER_LISTENER_NAMES=CONTROLLER \ -e KAFKA_LOG_DIRS=/var/lib/kafka/data \ -e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1 \ -e KAFKA_CLUSTER_ID=$(uuidgen) \ apache/kafka:latest KAFKA_MODE=KRaft 表示你要启动的是 KRaft 模式。 KAFKA_KRAFT_MODE=true 指定 Kafka 以 KRaft 模式启动。命令行测试
docker exec -it kafka /bin/bash cd /opt/kafka/bin 创建主题 ./kafka-topics.sh --bootstrap-server localhost:9092 --create --topic test-topic --partitions 1 --replication-factor 1 生产消息 ./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test-topic 消费消息 ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-topic --from-beginning 