kafka in docker

kafka in docker

这货基本上已经成为消息中间件的霸主,每秒支持数百万的消息吞吐。其大量用于日志中间件或实时流计算,支持集群负载均衡,为Apache顶级项目。
以下为借助docker快速搭建kafka单机测试环境:test kafka in docker。

kafka单机部署

zookeeper

docker run -d --name=cpplaZookeeper -p x.x.x.x:2181:2181 \
-v /etc/localtime:/etc/localtime \
zookeeper:latest

kafka

docker run -d --name cpplaKafka -p x.x.x.x:9092:9092 \
--link cpplaZookeeper:zookeeper \
--env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \
--env KAFKA_ADVERTISED_HOST_NAME=x.x.x.x \
--env KAFKA_ADVERTISED_PORT=9092 \
-v /etc/localtime:/etc/localtime \
wurstmeister/kafka:latest

注:KAFKA_ADVERTISED_HOST_NAME要设置为宿主机的IP地址,多IP服务器中设置最好为主出口IP【这里是在多服务器设置遇到的坑】

kafka消息测试

  • 创建主题:bin/kafka-topics.sh –create –zookeeper zookeeper:2181 –replication-factor 1 –partitions 1 –topic cppla
  • 查看主题:bin/kafka-topics.sh –list –zookeeper zookeeper:2181
  • 生产者:bin/kafka-console-producer.sh –broker-list localhost:9092 –topic cppla
  • 消费者:bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic cppla –from-beginning

生产消息测试

消费消息测试

kafka单机压力测试

发表评论

电子邮件地址不会被公开。 必填项已用*标注