kafka_2.11 - 2.0.0 버 전 클 러 스 터 구축

1, 다운로드 kafka
주소:https://www.apache.org/dyn/closer.cgi?path=/kafka/2.0.0/kafka_2.11-2.0.0.tgz
2. zookeeper 설치
참고http://www.zhangyitian.cn/blog/ubuntu16-04%E5%AE%89%E8%A3%85%E9%85%8D%E7%BD%AEzookeeper%E9%9B%86%E7%BE%A4/
 
3. zookeeper 시작
4. 같은 랜 아래 서로 다른 노드 의 kafka 군집 을 설정 합 니 다.

cd kafka
  kafka
cd /home/lin/kafka/kafka_2.11-2.0.0/config
sudo gedit server.properties

server. properties 의 4 가지 내용 수정
broker. id: 기계 마다 log. dirs: 메시지 저장 디 렉 터 리 가 같 을 수 없습니다.
listeners: 클 러 스 터 를 설정 할 때 설정 해 야 합 니 다. 그렇지 않 으 면 나중에 leader 의 오 류 를 찾 을 수 없습니다.
zookeeper. connect: 저 는 zookeeper 서버 가 3 대 있 기 때문에 여기 서 zookeeper. connect 를 3 대로 설정 하고 모두 넣 어야 합 니 다.

 heron04     

broker.id=0

listeners=PLAINTEXT://192.168.2.103:9092

log.dirs=/home/lin/kafka/log

zookeeper.connect=192.168.2.101:2181,192.168.2.102:2181,192.168.2.103:2181,192.168.2.104:2181

5. kafka 시작
노드 마다 한 번 씩 반복 해 야 돼 요.

cd /home/lin/kafka/kafka_2.11-2.0.0

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

6. 토픽 생 성

cd bin

./kafka-topics.sh --create --zookeeper 192.168.2.103:2181,192.168.2.104:2181,192.168.2.101:2181,192.168.2.102:2181 --replication-factor 4 --partitions 1 --topic test111

7, describe topics 명령 을 사용 하여 각 broker 보기

./kafka-topics.sh --describe --zookeeper 192.168.2.103:2181,192.168.2.104:2181,192.168.2.101:2181,192.168.2.102:2181 --topic test111

8. producer 시작 (192.168.2.103)

./kafka-console-producer.sh --broker-list 192.168.2.103:9092 --topic test111

9. consumer 시작 (192.168.2.102)

     0.9          
./kafka-console-consumer.sh --zookeeper 192.168.2.101:2181 --topic test111 --from-beginning

    
./kafka-console-consumer.sh --bootstrap-server 192.168.2.102:9092 --topic test111 --from-beginning

10. kafka 클 러 스 터 성공 실행