docker-compose-kafka-cluster

  17  sudo apt-get remove docker docker-engine docker.io
   18  apt-get install docker-ce
   19  sudo add-apt-repository    "deb [arch=amd64] https://download.docker.com/linux/ubuntu \
   20     $(lsb_release -cs) \
   21     stable"
   22  apt update
   23  sudo curl -L https://github.com/docker/compose/releases/download/1.21.0/docker-compose-$(uname -s)-$(uname -m) -o /usr/local/bin/docker-compose
   24  sudo chmod +x /usr/local/bin/docker-compose
   25  docker-compose --version
   26  cd
   27  ls
   28  docker-compose ps
   29  docker-compose 
   30  docker-compose ps
   31  telnet localhost 19092
   32  telnet localhost 29092
   33  docker-compose start kafka-cluster_kafka-1_1
   34  docker-compose restart kafka-cluster_kafka-1_1
   35  docker-compose
   36  docker-compose up kafka-cluster_kafka-1_1
   37  docker-compose ps
   38  ls
   39  docker-compose restart
   40  docker-compose ps
   41  docker-compose stop kafka-cluster_kafka-1_1
   42  docker-compose ps
   43  docker-compose 
   44  docker-compose ps
   45  docker-compose down kafka-cluster_kafka-1_1
   46  docker-compose stop kafka-cluster_kafka-1_1
   47  docker-compose ps
   48  ls
   49  cat docker-compose.yml 
   50  docker-compose stop kafka-3
   51  docker ps
   52  docker-compose ps kafka-3
   53  docker-compose ps 
   54  docker-compose start kafka-3
   55  docker-compose ps 
   56* docker-compose exec 
   57  docker-compose exec kafka-3  bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic
   58  man docker
   59  docker run   --net=host   --rm   confluentinc/cp-kafka:3.2.0   kafka-topics --create --topic bar --partitions 3 --replication-factor 3 --if-not-exists --zookeeper localhost:32181
   60  docker-compose exec kafka  kafka-topics --create --topic foo --partitions 1 --replication-factor 1 --if-not-exists --zookeeper localhost:32181
   61  ls
   62  cat docker-compose.yml 
   63  docker-compose exec kafka  kafka-topics --create --topic foo --partitions 1 --replication-factor 1 --if-not-exists --zookeeper localhost:32181
   64  docker-compose exec kafka-1  kafka-topics --create --topic foo --partitions 3 --replication-factor 1 --if-not-exists --zookeeper localhost:32181
   65  docker-compose exec kafka    kafka-topics --describe --topic foo --zookeeper localhost:32181
   66  docker-compose exec kafka-3    kafka-topics --describe --topic foo --zookeeper localhost:32181
   67  docker-compose exec kafka    bash -c "seq 42 | kafka-console-producer --request-required-acks 1 --broker-list localhost:29092 --topic foo && echo 'Produced 42 messages.'"
   68  docker-compose exec kafka-3    bash -c "seq 42 | kafka-console-producer --request-required-acks 1 --broker-list localhost:29092 --topic foo && echo 'Produced 42 messages.'"
   69  docker-compose exec kafka    kafka-console-consumer --bootstrap-server localhost:29092 --topic foo --from-beginning --max-messages 42
   70  docker-compose exec kafka-3    kafka-console-consumer --bootstrap-server localhost:29092 --topic foo --from-beginning --max-messages 42