- Getting started with Kafka
- Use docker compose to create Kafka cluster
./start-kafka
- Connect to kafka
- VS Code (From recommended extensions)
- UI for Apache Kafka (Already part of local docker-compose.yaml)
- Create Topics - learn about different options while creating topics
- Use extension
- Use UI
- Use CLI (Hint: exec into broker container)
- Test cluster using command line
- Produce and consume from CLI
- Produce from CLI - see the messages in the UI and the VS Code Extension
- Create python project
- Hint: You need to use 3.9
- Install
confluent-kafka
with pip
- Create simple python producer
- Create simple python consumer
- Add method to send batch of messages in producer
- Add method to receive batch of messages in consumer
- Create at-least once consumer
- Create at most once consumer
- Create exactly once consumer using transactions
- Create consumer that handles de-duplication
- Good to know
-
Notifications
You must be signed in to change notification settings - Fork 2
License
rguthriemsft/kafkatesting
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
No description, website, or topics provided.
Resources
License
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published