Kafka
in Getting Started on Kafka
Kafka
Download
$ wget https://downloads.apache.org/kafka/3.2.0/kafka_2.13-3.2.0.tgz
$ wget https://archive.apache.org/dist/kafka/2.5.0/kafka_2.12-2.5.0.tgz
Run
Zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
bin/zookeeper-server-stop.sh
Kafka server (broker)
config/server.properties
advertised.listeners=PLAINTEXT://localhost:9092
bin/kafka-server-start.sh -daemon config/server.properties
bin/kafka-server-stop.sh
tail -f logs/server.log
Test
통신 확인
bin/kafka-broker-api-versions.sh --bootstrap-server 3.18.137.216:9092
.\bin\windows\kafka-broker-api-versions.bat --bootstrap-server 3.18.137.216:9092
Create topic
bin/kafka-topics.sh --create --topic test-events --bootstrap-server localhost:9092
bin/kafka-topics.sh --describe --topic test-events --bootstrap-server localhost:9092
bin/kafka-topics.sh --list bootstrap-server localhost:9092
Send message (producer)
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test-events
>test
>test
Get message (comsumer)
bin/kafka-console-consumer.sh --topic test-events --from-beginning --bootstrap-server localhost:9092
