Stats
Actions
Tags
Help us improve
Share bugs, ideas, or general feedback.
From golang-boost
Constructs raw Kafka producers and consumers using the Confluent client via github.com/xgodev/boost/factory/contrib/confluentinc/confluent-kafka-go/v2. Covers NewProducer/NewConsumer and canonical examples.
npx claudepluginhub xgodev/boost --plugin golang-boostHow this skill is triggered — by the user, by Claude, or both
Slash command
/golang-boost:boost-factory-kafkaThis skill is limited to the following tools:
The summary Claude sees in its skill listing — used to decide when to auto-load this skill
**REQUIRED BACKGROUND:** `boost-start`, `boost-wrapper-config`. For event-handler integration (CloudEvents + middleware chain) → `boost-bootstrap-adapter-kafka`.
Constructs a Goka emitter (Kafka stream-processing producer) via the boost factory. Use when publishing to a Goka-managed Kafka stream consumed by downstream Goka processors.
Use when the user wants to build a Python Kafka producer or consumer, add Schema Registry to existing Python code, migrate from raw JSON to schema-backed serialization, or scaffold a confluent-kafka-python project for Confluent Cloud or local Docker.
Scaffolds a production-ready Python Kafka producer/consumer with confluent-kafka-python, Schema Registry, graceful shutdown, idempotent producer, and tests. Discovers topic and schema from any attached Kafka MCP server.
Share bugs, ideas, or general feedback.
REQUIRED BACKGROUND: boost-start, boost-wrapper-config. For event-handler integration (CloudEvents + middleware chain) → boost-bootstrap-adapter-kafka.
factory/contrib/confluentinc/confluent-kafka-go/v2/examples/producer/main.gofactory/contrib/confluentinc/confluent-kafka-go/v2/examples/consumer/main.goimport kafkafact "github.com/xgodev/boost/factory/contrib/confluentinc/confluent-kafka-go/v2"
producer, err := kafkafact.NewProducer(ctx)
consumer, err := kafkafact.NewConsumer(ctx)
Configure brokers, group id, security under boost.factory.kafka.* (override BOOST_FACTORY_KAFKA_*).
| Use case | Reach for |
|---|---|
| Custom Kafka pipeline (low-level Poll, manual offset commit) | boost-factory-kafka (raw client) |
| Event handler over CloudEvents semantics with middleware chain | boost-bootstrap-adapter-kafka |
| Red flag | Fix |
|---|---|
kafka.NewProducer(&kafka.ConfigMap{...}) directly | kafkafact.NewProducer(ctx) |
Brokers/groupID via os.Getenv | BOOST_FACTORY_KAFKA_* |
Forgetting producer.Close() / consumer.Close() on shutdown | Add it |