Using Kafka to Produce and Consume Messages Between Applications - FastAPI (Python)

preview_player
Показать описание
In this video, I go over how to create a producer to send messages to a kafka topic and how to create a consumer to poll and consume messages from the kafka topic. You will also learn how to use the admin client to add or delete a topic using python code. Hope it helps! Thanks for watching!

Help my Coffee Addiction:

My Setup Gear
Disclaimer: I do get paid a percentage for any purchase made using any of the following links

00:00 Introduction
00:50 Docker Compose Zookeeper & Kafka
06:38 What will be done?
07:02 Producer Application Setup
08:28 Produce Message Schema
10:47 Intialize Producer & Helper Function
17:52 Creating a Topic with KafkaAdminClient
24:51 Creating Produce Message Route
30:16 Consumer Apllication Setup
31:56 Consumer Code Imports
33:44 Purpose for Consumer Application
34:38 Consumer Code
46:55 Consumer Trigger Endpoints
53:35 Testing the Applications

#tech #python #fastapi #kafka #eventdrivenarchitecture #techwithgio
Рекомендации по теме
Комментарии
Автор

pretty good video, had a good hands-on experience. thanks!

shreyaskulkarni
Автор

Disclaimer : Asyncio utilizes tasks not threads just for clarification

techwithgio
visit shbcf.ru