Docker部署Kafka Raft模式(单节点):
docker run \
--cpus 1 -m 1g \
-d \
-p 9092:9092 \
-v /tmp/kraft-combined-logs:/tmp/kraft-combined-logs \
--name kafka-raft-3.0.0 kubebiz/kafka:2.13-3.0.0 \
/bin/bash -c "kafka-storage.sh format --cluster-id AAAAAAAAAAAAAAAAAAAAAA \
--config /opt/kafka/config/kraft/server.properties && \
exec kafka-server-start.sh /opt/kafka/config/kraft/server.properties"
需要持久化的,自己改-v
路径。
获取docker容器ip
docker inspect --format='{{.NetworkSettings.IPAddress}}' kafka-raft-3.0.0
获得容器ip"172.17.0.2"。
生产者测试:
bin/kafka-console-producer.sh --broker-list 172.17.0.2:9092 --topic test
消费者:
bin/kafka-console-consumer.sh --bootstrap-server 172.17.0.2:9092 --from-beginning --topic test --consumer.config config/consumer.properties
以上。
单机版吞吐量可以达到千万级,适合快速体验、开发和调试的场景。