docker 배포kafka (1)

1025 단어 kafkadcoker서버
1. 미러 다운로드
여기는wurstmeister/kafka와wurstmeister/zookeeper 두 버전의 거울을 사용했습니다.
docker pull wurstmeister/zookeeper docker pull wurstmeister/kafka
명령에서 docker 이미지를 실행하면 두 개의 미러가 설치되었는지 확인합니다.
2, 시작
1、 zookeeper

        docker run -d --name zookeeper -p 2181 -t wurstmeister/zookeeper  

2、 kafka

        docker run --name kafka -e HOST_IP=localhost -e KAFKA_ADVERTISED_PORT=9092 -e KAFKA_BROKER_ID=1 -e ZK=zk -p 9092 --link zookeeper:zk -t wurstmeister/kafka  

 docker ps  

3. 메시지 보내기 테스트
         Docker ps, kafka Container ID, :

        docker exec -it ${CONTAINER ID} /bin/bash 

         kafka 

        cd opt/kafka_2.11-0.10.1.1/   

 kafka 
 :     

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

 , topic 

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

 , 

bin/kafka-console-consumer.sh --zookeeper zookeeper:2181 --topic mykafka --from-beginning

 , 

좋은 웹페이지 즐겨찾기