B. Instalasi Apache Kafka

Instalasi dengan Docker

Pada materi ini kita akan instalasi apache kafka dan kafka ui dengan docker agar kita tidak bermasalah dengan sistem operasi. Agar proses instalasi lebih mudah kita gunakan docker compose , silahkan teman-teman buat file baru dengan nama docker-compose.yml di aplikasi nestjs .

docker-compose.yml

version: '3.8'
services:
  zookeeper:
    image: wurstmeister/zookeeper:latest
    container_name:  zookeeper
    restart: always
    ports:
      - "2181:2181"

  kafka:
    image: wurstmeister/kafka:latest
    container_name:  kafka
    restart: always
    ports:
      - "9092:9092"
    expose:
      - "9093"
    environment:
      KAFKA_ADVERTISED_LISTENERS: INSIDE://kafka:9093,OUTSIDE://localhost:9092
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INSIDE:PLAINTEXT,OUTSIDE:PLAINTEXT
      KAFKA_LISTENERS: INSIDE://0.0.0.0:9093,OUTSIDE://0.0.0.0:9092
      KAFKA_INTER_BROKER_LISTENER_NAME: INSIDE
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
    depends_on :
      - zookeeper

  kafka-ui:
    image: provectuslabs/kafka-ui:latest
    container_name:  kafka-ui
    restart: always
    ports:
      - "8080:8080"
    depends_on :
      - kafka
      - zookeeper
    environment:
      KAFKA_CLUSTERS_0_NAME: local
      KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: kafka:9093
      KAFKA_CLUSTERS_0_ZOOKEEPER: zookeeper:2181

untuk proses instalasi kita tinggal menjalankan docker-compose up -d

terminal

docker-compose up -d

Membuat Topic pada Kafka UI

Setelah proses instalasi kafka dan kafka UI, silahkan teman-teman buka kafka ui dengan mengakses localhost:8080

Untuk belajar memulai kafka silakan buat topic baru seperti konfigurasi seperti di bawah ini.

Produce Message pada kafka dengan Kafka UI