| name | kafka-k8s-setup |
| description | Deploy Apache Kafka on Kubernetes with Helm |
Kafka Kubernetes Setup
When to Use
- User asks to deploy Kafka for event-driven architecture
- Setting up message broker for microservices
- Need pub/sub messaging for LearnFlow platform
Instructions
Deploy Kafka
- Run deployment:
python scripts/deploy.py --namespace kafka --replicas 1
- Wait for completion (shows progress)
- Verify status:
python scripts/verify.py --namespace kafka
Create Topics
- List topics:
python scripts/topic_manager.py list --namespace kafka
- Create topic:
python scripts/topic_manager.py create <topic-name> --partitions 3 --replicas 1
- Delete topic:
python scripts/topic_manager.py delete <topic-name>
Test Connectivity
- Run test producer:
python scripts/test_connection.py produce --namespace kafka
- Run test consumer:
python scripts/test_connection.py consume --namespace kafka
Validation
Configuration Options
--replicas: Number of Kafka brokers (default: 1 for dev, 3 for prod)
--persistence: Enable persistent storage (default: false for dev)
--resources: CPU/memory limits
See REFERENCE.md for advanced configuration and troubleshooting.