spring-webflux-kafka

카프카 테스트 어플리케이션

Tech Stack

• Kotlin
• SpringBoot
• Reactor Kafka
• WebFlux

Docker를 통한 Zookeeper + Kafka + KafkaManager

kafka-gui.yml

version: "2.2"
services:
  kafka:
    image: wurstmeister/kafka
    container_name: kafka
    depends_on:
      zookeeper:
        condition: service_healthy
    ports:
    - 9092:9092
    environment:
      KAFKA_ADVERTISED_HOST_NAME: 127.0.0.1
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
  zookeeper:
    image: zookeeper
    container_name: zookeeper
    hostname: zookeeper
    ports:
      - 2181:2181
    environment:
      ZOO_MY_ID: 1
    healthcheck:
      test: "exit 0"
  kafka_manager:
    image: hlebalbau/kafka-manager:stable
    container_name: kakfa-manager
    ports:
      - "9000:9000"
    environment:
      ZK_HOSTS: "zookeeper:2181"
      APPLICATION_SECRET: "random-secret"
    command: -Dpidfile.path=/dev/null

실행

docker-compose -f ./kafka-gui.yml up