[Kafka] 1.Cài Đặt Kafka Server Trong 1 Phút

Cài Đặt Kafka Trên Mac

• Chỉ cần dùng 2 câu lệnh sau:

brew install kafka
brew install java

• Sau khi cài đặt thành công, run 2 câu lệnh để start zookeeper và kafka

zookeeper-server-start /opt/homebrew/etc/kafka/zookeeper.properties
kafka-server-start /opt/homebrew/etc/kafka/server.properties

Cài Đặt Kafka Use Docker

• tạo file docker-compose.yaml

version: "2"

services:
  zookeeper:
    image: docker.io/bitnami/zookeeper:3.8
    ports:
      - "2181:2181"
    volumes:
      - "zookeeper_data:/bitnami"
    environment:
      - ALLOW_ANONYMOUS_LOGIN=yes
  kafka:
    image: docker.io/bitnami/kafka:3.2
    ports:
      - "9092:9092"
    volumes:
      - "kafka_data:/bitnami"
    environment:
      - KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper:2181
      - ALLOW_PLAINTEXT_LISTENER=yes
    depends_on:
      - zookeeper

volumes:
  zookeeper_data:
    driver: local
  kafka_data:
    driver: local

Một vài câu lệnh đơn giản

• create topic:

kafka-topics --create --topic demo --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 

• list topic:

kafka-topics --list --bootstrap-server localhost:9092

• view topic:

kafka-topics --describe --topic demo --bootstrap-server localhost:9092

• list topic:

kafka-topics --list --bootstrap-server localhost:9092

• push message vào topic

kafka-console-producer --broker-list localhost:9092 --topic demo

• đọc message từ topci:

kafka-console-consumer --bootstrap-server localhost:9092 --topic demo --from-beginning

• delete topic:

kafka-topics --delete --topic demo --bootstrap-server localhost:9092