Run Kafka by docker

 https://itnext.io/how-to-install-kafka-using-docker-a2b7c746cbdc


  1. Create network
$ sudo docker network create kafka-net --driver bridge

  1. Install zookeeper container
$ sudo docker run -d --name zookeeper-server -p 2181:2181 --network kafka-net -e ALLOW_ANONYMOUS_LOGIN=yes bitnami/zookeeper:latest

  1. install kafka
$ sudo docker run -d --name kafka-server1 --network kafka-net -e ALLOW_PLAINTEXT_LISTENER=yes -e KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper-server:2181 -e KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092 -p 9092:9092 bitnami/kafka:latest

  1. check kafka ip
$ sudo docker inspect --format='{{range .NetworkSettings.Networks}}{{.IPAddress}}{{end}}' kafka-server1
172.18.0.2

  1. get metadata by kafkacat
$ sudo docker run -it --network=kafka-net edenhill/kafkacat:1.6.0 -b `sudo docker inspect --format='{{range .NetworkSettings.Networks}}{{.IPAddress}}{{end}}' kafka-server1` -L
Metadata for all topics (from broker -1: 172.18.0.2:9092/bootstrap):
1 brokers:
broker 1001 at localhost:9092 (controller)
0 topics:




沒有留言:

張貼留言

別名演算法 Alias Method

 題目 每個伺服器支援不同的 TPM (transaction per minute) 當 request 來的時候, 系統需要馬上根據 TPM 的能力隨機找到一個適合的 server. 雖然稱為 "隨機", 但還是需要有 TPM 作為權重. 解法 別名演算法...