다운로드URL : https://kafka.apache.org/quickstart
Last login: Thu Jun 7 10:31:19 2018 from 116.122.223.193 100%[===================================================================================================================================================================================================>] 56,969,154 7.86MB/s in 6.9s 2018-06-07 14:49:41 (7.83 MB/s) - ‘kafka_2.11-1.1.0.tgz’ saved [56969154/56969154] [sooabia@docker-registry ~]$ [sooabia@docker-registry ~]$ tar xvfz kafka_2.11-1.1.0.tgz [sooabia@docker-registry ~]$ ll |
[sooabia@docker-registry kafka]$ bin/zookeeper-server-start.sh config/zookeeper.properties |
[sooabia@docker-registry kafka]$ |
단일 파티션과 하나의 복제본으로 "test"라는 Topic을 만듭니다.
Created topic "test". <<Topic List 확인>>
test |
[sooabia@docker-registry kafka]$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test |
[sooabia@docker-registry kafka]$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning |