Stats
Actions
Tags
Help us improve
Share bugs, ideas, or general feedback.
From golang-boost
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.
npx claudepluginhub xgodev/boost --plugin golang-boostHow this skill is triggered — by the user, by Claude, or both
Slash command
/golang-boost:boost-factory-gokaThis 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 raw Kafka producer/consumer → `boost-factory-kafka`.
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.
Produces and consumes Kafka messages using KafkaJS with partitioning, consumer groups, offset management, and transactions for event streaming, sourcing, and CDC pipelines.
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.
Share bugs, ideas, or general feedback.
REQUIRED BACKGROUND: boost-start, boost-wrapper-config. For raw Kafka producer/consumer → boost-factory-kafka.
import gokafact "github.com/xgodev/boost/factory/contrib/lovoo/goka/v1"
emitter, err := gokafact.NewEmitter(ctx)
if err != nil { log.Fatalf("goka: %v", err) }
defer emitter.Finish()
Configure brokers, stream name, codec under boost.factory.goka.* (override BOOST_FACTORY_GOKA_*).
Goka adds stream-processing semantics (key/value tables, joins, group processors) on top of Kafka. Use Goka when your service participates in a Goka topology; use raw Kafka (boost-factory-kafka) when you just need produce/consume.
The publisher driver wrapper/publisher/driver/contrib/lovoo/goka/v1 (see boost-wrapper-publisher) wraps this emitter for the function publisher middleware path.
| Red flag | Fix |
|---|---|
goka.NewEmitter(...) directly | gokafact.NewEmitter(ctx) |
Brokers via os.Getenv | BOOST_FACTORY_GOKA_* |
Forgetting emitter.Finish() on shutdown | Add it — flushes pending writes |