faststream_overview

Description

• A little extended example of working with faststream framework
• You can run kafka in docker and run the application with data processing and generation
• Also you can observe the data processing in kafka-ui

Application installation

• Clone repository

• Set up a virtual environment and install dependicies:

python -m venv venv

or

pyenv virtualenv 3.12.3 kafka_example

poetry install

• Available commands:

make help

• Run kafka as a broker

make kafka

UI endpoint - http://localhost:8080/overview

• Setup environment variables:

cd dev && source set_env.sh

Run example in docker

• To run the docker work example:

make main

OpenAPI endpoint - http://localhost:9000/docs

Prometheus metrics endpoint - http://localhost:9000/metrics

• generated data is sent to the consume topic

• the data after processing is sent to the pub topic

• The data generation logs are as follows:

• The data processing logs are as follows: