Docker部署Kafka Raft模式(单机版)

半兽人 发表于: 2021-12-01   最后更新时间: 2021-12-01 19:39:52  
{{totalSubscript}} 订阅, 1,177 游览

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

以上。

单机版吞吐量可以达到千万级,适合快速体验、开发和调试的场景。

更新于 2021-12-01
在线,2小时前登录

查看kafka更多相关的文章或提一个关于kafka的问题,也可以与我们一起分享文章
提问