docker下搭建kafka服務相關命令

2021-09-24 09:56:12 字數 2026 閱讀 6626

docker start zookeeper


sudo docker run -d --name kafka --publish 9092:9092 --link zookeeper --env kafka_zookeeper_connect=zookeeper:2181 --env kafka_advertised_host_name=127.0.0.1 --env kafka_advertised_port=9092 --volume /users/liweijun/downloads:/etc/localtime wurstmeister/kafka


#進入kafka目錄


docker exec -ti kafka /bin/bash


cd /opt/kafka_2.12-2.2.0/bin


#後面的操作在linux下都相同


#啟動kafka


sh kafka-server-start.sh ../config/server.properties


#config/server.properties可以配置監聽（多個埠需配置多個配置檔案在kafka啟動時選定對應的配置檔案即可）


#如#server1.properties


#advertised.listeners=plaintext: 


#port=9092


#server2.properties


#advertised.listeners=plaintext: 


#port=9093


#啟動zookeeper


bin/zookeeper-server-start.sh config/zookeeper.properties &


#啟動kafka


bin/kafka-server-start.sh config/server.properties &


#停止kafka


bin/kafka-server-stop.sh


#停止zookeeper


bin/zookeeper-server-stop.sh


#開啟zookeeper埠


firewall-cmd --zone=public --add-port=2181/tcp --permanent


#開啟kafka埠


firewall-cmd --zone=public --add-port=9092/tcp --permanent


#重啟firewall


firewall-cmd --reload 


#建立topic


bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test


#展示topic


bin/kafka-topics.sh --list --zookeeper localhost:2181


#描述topic


bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic


#生產者：


bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-replicated-topic


#消費者：


bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginnin


#如果建立消費者報錯 consumer zookeeper is not a recognized option請使用下面命令


bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning


#檢視topic


bin/kafka-topics.sh --list --zookeeper localhost:2181

docker簡單搭建kafka

zookeeper不記錄 執行 docker run dit name kafka 01 p 9092 9092 e kafka broker id 0 e kafka zookeeper connect 192.168.1.63 2181 e kafka advertised listeners ...

Linux下搭建kafka環境

apache官網 tar xzf kafka 2.10 0.8.2.2.tgz cd kafka 2.10 0.8.2.2 啟動zk有兩種方式，第一種是使用kafka自己帶的乙個zk。bin zookeeper server start.sh config zookeeper.properties ...

Linux下搭建kafka環境

apache官網 tar xzf kafka 2.10 0.8.2.2.tgz cd kafka 2.10 0.8.2.2 3.啟動服務 3.1 啟動zookeeper 啟動zk有兩種方式，第一種是使用kafka自己帶的乙個zk。bin zookeeper server start.sh confi...