브로커 설치하기

자바와 주키퍼가 설정되었다면 카프카를 설치할 준비가 끝난 셈이다. 카프카의 현재 버전은 공식웹사이트(http://kafka.apache.org/downloads) 에서 받을 수 있다. 현재 시점의 최신 버전은 스칼라 2.13.0에서 실행되는 3.6.1 버전이다.

 

1. 브로커 설치

다운받은 카프카를 /usr/local/kafka 에 설치하고, 메시지 로그는 /tmp/kafka-logs 에 저장한다.

1. 배포판 다운로드 및 압축해제

2. /usr/local/kafka 로 이동

3. 로그 디렉토리 생성(/tmp/kafka-logs)

4. JAVA 환경설정 및 서버실행

$ tar -zxf kafka_2.13-3.6.1.tgz 
$ mv kafka_2.13-3.6.1 /usr/local/kafka
$ mkdir /tmp/kafka-logs
$ export JAVA_HOME=/usr/java/jdk-17.0.9
$ /usr/local/kafka/bin/kafka-server-start.sh -daemon \
	/usr/local/kafka/config/server.propertis
$

 

브로커가 시작되었다면, 클러스터에 간단한 명령 몇 개를 실행(테스트 토핑 생성, 메시지 쓰기, 메시지 읽기)시킴으로써 제대로 작동하는지 확인할 수 있다. 

토픽 생성

$ /usr/local/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 \
	--create --replication-factor 1 --partitions 1 --topic test
Created topic "test".
$
$ /usr/local/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 \
	--describe --topic test
Topic:test PartitionsCount:1 ReplicationFactor:1 Configs:
	Topic:test Partition: 0 Leader: 0 Replicas: 0 Isr: 0
$

메시지 쓰기

위에서 생성한 test 토픽에 메시지를 쓴다.

$ /usr/local/kafka/bin/kafka-console-producer.sh --bootstrap-server
	localhost:9092 --topic test
Test Message 1
Test Message 2
^C
$

메시지 읽기

test 토픽에서 메시지를 읽는다.

$ /usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server
	localhost:9092 --topic test --from-beginning
Test Message 1
Test Message 2
^C
Processed a totoal of 2 messages
$