1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
| # yum install java-1.8.0-openjdk.x86_64
# vi /etc/profile
profile 파일 안에 아래의 내용을 추가
export JAVA_HOME=/usr/lib/jvm/jre-1.8.0-openjdk
export JRE_HOME=/usr/lib/jvm/jre
source 명령어를 이용해서 변경된 내용 적용
# source /etc/profile
# yum install -y wget
# wget http://www-us.apache.org/dist/kafka/2.3.0/kafka_2.11-2.3.0.tgz
# tar xvf kafka_2.11-2.3.0.tgz
# mv kafka_2.11-2.3.0 /opt
# cd /opt/kafka_2.11-2.3.0/
# vi conifg/server.properties
아래 두줄 추가
port = 9092
advertised.host.name = localhost (서버주소를 입력하는것인데 vm상에서 띄울때는 서버가 될 주소 입력)
서버 시작
# ./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
# ./bin/kafka-server-start.sh -daemon config/server.properties
토픽 생성
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
토픽 조회
# ./bin/kafka-topics.sh --list --zookeeper localhost:2181
Producer
# ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
Consumer
# ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
# ./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
컨슈머 그룹 확인
./kafka-consumer-groups.sh --all-groups --list --bootstrap-server localhost:9092
실시간 변화 확인
$ watch -d -n 1 './kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group console-consumer-33229 --describe'
|