Kafka Demonstrator

Overview

Components

• Apache Server
• Frontend as Web App by Flask
• Backend as Kafka Cluster by Confluent

Getting started

docker compose up --build -d

You have to wait a few seconds until the control-center is ready.

How to...

Stop a running broker

docker-compose stop kafka1|kafka2|kafka3

Restart a stopped broker

docker-compose up kafka1|kafka2|kafka3

Try it yourself:

Create topic

docker exec kafka2 kafka-topics --create --topic vks --bootstrap-server kafka2:29092 --replication-factor 2 --partitions 2

Create consumer

docker exec -it schema-registry bash
kafka-avro-console-consumer --topic vks --bootstrap-server kafka2:29092

Create producer

docker exec -it schema-registry bash
kafka-avro-console-producer --topic vks --bootstrap-server kafka2:29092 --property value.schema="$(</opt/app/schema/user_login.avsc)"

Send a message

Enter this in your producer:

{"ID": 1,"username":"Max"}

Access user interface

• Frontend Web App
• Backend Control Center

Acknowledgment

• Docker containers from Confluent Images
• Python client from Confluent Package