sk Skill · lensesio
kafka-python-client
Scaffold a production-ready Python Kafka producer and consumer using confluent-kafka-python, with Schema Registry, graceful shutdown, idempotent producer, tests and a complete project layout. Discovers the target topic, partition count and registered JSON Schema directly from the live cluster via any attached Kafka MCP server (Lenses MCP, Confluent's MCP, Aiven's, custom) before asking the user. Use when user says…
Open on skills.sh ↗read 2026-09-15
- installs 8w
- 0
- 30-day movement
- starts with the next reading
- Related entries
- 1
- Connections
- 6
tomlbashmcp-agnosticjson-schemaPythonscaffoldschema-registryconsumerproducerworkflow-automationpythonkafka
- Host repository
- lensesio/agentic-engineering-for-apache-kafka
- Category
- workflow-automation
- Version
- 1.0.0
- Allowed tools
- Read, Grep, Glob, Bash, Write, mcp__*
- Compatible with
- Works with any Kafka MCP server (Lenses MCP, Confluent MCP, AivenLabs MCP, the skill falls back to a hard gate that asks the user for topic, schema and cluster details directly.
- Licence
- MIT
- Host stars
- 57
- Host language
- Python