togo-framework/queue-kafka

Part of the togo framework.

Install

togo install togo-framework/queue-kafka

A togo queue backend backed by Apache Kafka (topic per job name). Implements togo.Queue.

togo install togo-framework/queue-kafka
togo provider:use queue kafka
togo config:set KAFKA_BROKERS localhost:9092

Key	Default	Purpose
KAFKA_BROKERS	localhost:9092	comma-separated brokers
KAFKA_GROUP	togo	consumer group

---

💎 Premium sponsors

    

_{Support togo — become a sponsor.}