raspberry pi 4에 kafa 설치

자바설치

$sudo apt update

$sudo apt install default-jdk

$java --version

 

Kafka 설치

https://kafka.apache.org/downloads

Apache Kafka

https://kafka.apache.org/quickstart

Apache Kafka

 

$tar -xzf kafka_2.13-3.4.0.tgz

$cd kafka_2.13-3.4.0

~/kafka_2.13-3.4.0 $ mkdir data

~/kafka_2.13-3.4.0$mkdir data $ mkdir kafka

~/kafka_2.13-3.4.0$mkdir data $ mkdir zookeeper

 

• config/zookeeper.properties 를 열어서

dataDir 부분을 아래와 같이 수정

dataDir=/home/pi/kafka_2.13-3.4.0/data/zookeeper

 

• config/server.properties 를 열어서

아래 문장을 추가

listeners=PLAINTEXT://{your_ip_address}:9092

log.dirs 부분을 찾아서 아래와 같이 수정

log.dirs=/home/pi/kafka_2.13-3.4.0/data/kafka

 

 

Test Kafka

Zookeeper 실행

~/kafka_2.13-3.4.0 $ bin/zookeeper-server-start.sh config/zookeeper.properties

 

Kafka 실행

~/kafka_2.13-3.4.0 $ bin/kafka-server-start.sh config/server.properties

 

Topic 생성

bin/kafka-topics.sh --create --bootstrap-server {your_ip_address}:9092 --replication-factor 1 --partitions 1 --topic TestTopic

 

Topic 생성된것 확인

bin/kafka-topics.sh --list --bootstrap-server {your_ip_address}:9092

 

Kafka Producer 실행

bin/kafka-console-producer.sh --broker-list {your_ip_address}:9092 --topic TestTopic

 

Kafka Consumer 실행

bin/kafka-console-consumer.sh --bootstrap-server {your_ip_address}:9092 --topic TestTopic