kafka docker安装kafka

🧙 Questions

docker安装kafka

☄️ Ideas

scp /Users/ispong/OneDrive/Downloads/docker/debezium-zookeeper-3.0.0.Final-amd64.tar root@101.132.37.59:/tmp
scp /Users/ispong/OneDrive/Downloads/docker/debezium-kafka-3.0.0.Final-amd64.tar root@101.132.37.59:/tmp
docker load -i /tmp/debezium-kafka-3.0.0.Final-amd64.tar
docker load -i /tmp/debezium-zookeeper-3.0.0.Final-amd64.tar
rm -rf /tmp/debezium-kafka-3.0.0.Final-amd64.tar
rm -rf /tmp/debezium-zookeeper-3.0.0.Final-amd64.tar

mkdir -p /data/zookeeper/logs
mkdir -p /data/zookeeper/data
mkdir -p /data/zookeeper/txns
chmod -R 777 /data/zookeeper

docker run -it \
  --name isxcode-zookeeper \
  --privileged=true \
  --restart=always \
  -p 2181:2181 \
  -p 2888:2888 \
  -p 3888:3888 \
  -v /data/zookeeper/logs:/zookeeper/logs \
  -v /data/zookeeper/data:/zookeeper/data \
  -v /data/zookeeper/txns:/zookeeper/txns \
  -d debezium/zookeeper:3.0.0.Final

mkdir -p /data/kafka/logs
mkdir -p /data/kafka/data
chmod -R 777 /data/kafka

docker run -it \
  --name isxcode-kafka \
  --privileged=true \
  --restart=always \
  -p 9092:9092 \
  -p 443:30155 \
  -v /data/kafka/logs:/kafka/logs \
  -v /data/kafka/data:/kafka/data \
  -e ZOOKEEPER_CONNECT=172.19.215.157:2181 \
  -e KAFKA_INTER_BROKER_LISTENER_NAME=INTERNAL \
  -e KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=EXTERNAL:PLAINTEXT,INTERNAL:PLAINTEXT \
  -e KAFKA_LISTENERS=EXTERNAL://0.0.0.0:30155,INTERNAL://0.0.0.0:9092 \
  -e KAFKA_ADVERTISED_LISTENERS=EXTERNAL://101.132.37.59:30155,INTERNAL://localhost:9092 \
  -e KAFKA_HEAP_OPTS="-Xms256M -Xmx512M" \
  -d debezium/kafka:3.0.0.Final

docker exec -it isxcode-kafka /bin/bash
kafka-topics.sh --list --bootstrap-server localhost:9092
kafka-topics.sh --create --bootstrap-server localhost:9092 --topic ispong-topic --replication-factor 1 --partitions 1 
kafka-console-consumer --topic ispong-topic --bootstrap-server 101.132.37.59:443 
kafka-console-producer --topic ispong-topic --broker-list 101.132.37.59:443

🔗 Links

• kafka docs