Apache Kafka - Quick Start

카프카 얻기

다운로드 : https://kafka.apache.org/downloads

tar -xzf kafka_2.13-3.9.0.tgz
cd kafka_2.13-3.9.0

 

 

카프카 기동

Apache Kafka는 KRaft (Kafka Raft) 또는 ZooKeeper를 사용 하여 시작할 수 있다.

KRaft 모드

# Generate a Cluster UUID
KAFKA_CLUSTER_ID="$(bin/kafka-storage.sh random-uuid)"

# Format Log Directories
bin/kafka-storage.sh format -t $KAFKA_CLUSTER_ID -c config/kraft/server.properties

# start the kafka Server
bin/kafka-server-start.sh config/kraft/server.properties

zookeper 모드

# Start the ZooKeeper service
bin/zookeeper-server-start.sh config/zookeeper.properties

# Start the Kafka broker service
bin/kafka-server-start.sh config/server.properties

 

토픽 생성과 이벤트 쓰기/읽기

토픽 생성

bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

 

토픽 리스트 확인

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

 

토픽 상세 정보 확인

bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

Topic: quickstart-events        TopicId: x6lvVVcZRce6PKfHG_RoyQ PartitionCount: 1       ReplicationFactor: 1    Configs:
        Topic: quickstart-events        Partition: 0    Leader: 0       Replicas: 0     Isr: 0  Elr: N/A        LastKnownElr: N/A

 

이벤트 쓰기/읽기

# Write Events
bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
> hello
> world

# Read Events
bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
> hello
> world