kafka 설치/

$ java -version
-> 1.8.xxx

아래의 예제는 /root/에서 다 실행함. 

$ wget https://archive.apache.org/dist/kafka/2.0.0/kafka_2.12-2.0.0.tgz

$ tar -xzf kafka_2.12-2.0.0.tgz

<심볼릭 링크 만들기>

$ ln -s kafka_2.12-2.0.0 kafka

$ echo "export PATH=$PATH:/root/kafka_2.12-2.0.0/bin" >> ~/.bash_profile

$ source ~/.bash_profile

<kafka내장 주키퍼로 시작>

$ zookeeper-server-start.sh -daemon /root/kafka/config/zookeeper.properties

$ yum install telnet
<엑세스 여부 확인>
$ telnet localhost 2181

<기본속성으로 kafka를 시작>
$ kafka-server-start.sh -daemon /root/kafka/config/server.properties

<9092 확인>

$ telnet localhost 9092

<샘플 주제를 만든다>

$ kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic tecmint

<작성된 주제 나열>

$ kafka-topics.sh --zookeeper localhost:2181 --list