ARM_KAFKA搭建 一、搭建环境
安装路径为:/data/kafka
version: '3.2' services: zookeeper: image: zookeeper ports: - "2181:2181" privileged: true volumes: - /data/zook/data:/data - /data/zook/datalog:/datalog - /etc/localtime:/etc/localtime container_name: "zookeeper" restart: always kafka: image: wyh1791/kafka-arm64v8 container_name: "kafka" ports: - "9092:9092" privileged: true environment: - TZ=Asia/Shanghai - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 - KAFKA_AUTO_CREATE_TOPICS_ENABLE=true - KAFKA_ADVERTISED_HOST_NAME=20.10.0.xx - KAFKA_ADVERTISED_PORT=9092 - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://20.10.0.xx:9092 - KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 - KAFKA_HEAP_OPTS=-Xmx16G -Xms16G - KAFKA_LOG_RETENTION_HOURS=168 volumes: - /data/kafka/kafka_data:/kafka - /var/run/docker.sock:/var/run/docker.sock - /etc/localtime:/etc/localtime restart: always 2、kafka启动 docker-compose up -d #默认文件下可以这样启动,如果不是默认文件名 -f指定文件名进行启动 三、测试搭建部署好后,进行docker容器测试:
1、创建topic
/opt/kafka/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test2、topic列表查询
/opt/kafka/bin/kafka-topics.sh --zookeeper 20.10.0.xx:2181 --list3、启动kafka生产者
/opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test4、启动kafka消费者
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning总结:上述如果执行无问题,生产者、消费者互通并可消费到说明kafka搭建成功。进行程序连接测试。
1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,会注明原创字样,如未注明都非原创,如有侵权请联系删除!;3.作者投稿可能会经我们编辑修改或补充;4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。 |