• producer

  Spring Boot Web Java application that creates message and pushes topic in Kafka.

• consumer

  Spring Boot Web Java application that consumes message from topic in Kafka.

• Open a terminal and inside kafka root folder run

  docker-compose up -d

• Wait a until all containers are Up (healthy). You can check their status by running

  docker-compose ps

Inside kafka root folder, run the following Gradle commands in different terminals

• eureka-server

  ./gradlew :eureka-server:clean build

• producer

  ./gradlew :producer:clean build

• consumer

  ./gradlew :consumer:clean build

• Stop applications

  • If they were started with Gradle, go to the terminals where they are running and press Ctrl+C

  • If they were started as a Docker container, run the script below

    ./stop-apps.sh

• Stop and remove docker-compose containers, networks and volumes

  docker-compose down -v

• Eureka

  Eureka can be accessed at http://localhost:8761

• Kafka Topics UI

  Kafka Topics UI can be accessed at http://localhost:8085

• Zipkin

  Zipkin can be accessed at http://localhost:9411

  The figure below shows an example of the complete flow a request passes through. It goes since producer-api, where the message is created, until consumer-api.

  

• Kafka Manager

  Kafka Manager can be accessed at http://localhost:9000

  Configuration

  • First, you must create a new cluster. Click on Cluster (dropdown button on the header) and then on Add Cluster

  • Type the name of your cluster in Cluster Name field, for example: MyZooCluster

  • Type zookeeper:2181 in Cluster Zookeeper Hosts field

  • Enable checkbox Poll consumer information (Not recommended for large # of consumers if ZK is used for offsets tracking on older Kafka versions)

  • Click on Save button at the bottom of the page.