Скачать или смотреть Producer-consumer pattern - Kafka+FastAPI

🔧 Source Code
📂 GitHub Repository: https://github.com/brunolnetto/data-engine...

🧪 Step-by-Step Tutorial

This tutorial demonstrates how to use Kafka as a message broker with Python, FastAPI, and Docker. You’ll spin up a Kafka cluster and create both producer and consumer services.

Follow these steps to run it locally:

1. Clone the repo
git clone https://github.com/brunolnetto/data-engine...

2. Navigate to the Kafka project folder
cd stacks/compose/kafka-flink

3. Install Python dependencies
pip install -r requirements.txt

4. Start Kafka with Docker Compose
docker compose up -d

5. Run the producer service (in one terminal)
uvicorn main-producer:app --reload

6. Run the consumer service (in another terminal)
uvicorn main-consumer:app --reload

7. Send a test message
curl http://localhost:8000/send_message

💡 Pro Tip

Make sure Docker is running before you start. If you hit issues, check the container logs or Kafka port bindings.