Kafka Playground

Collection of experiments exploring interesting aspects of Kafka and its ecosystem. These are learning projects and proof-of-concepts rather than production-ready code.

Examples

Priority-Based Message Partitioning with Custom Balancer (Go)

Custom partitioner implementing the Bucket Priority Pattern to route urgent messages to dedicated partitions, in Go.

Backward-Compatible Avro Consumer (Python)

Single consumer handling multiple Avro schema versions through Schema Registry, in Python.

Setup

# Start Kafka with Schema Registry
docker-compose up -d