lovoo/goka

Health v2 · maintenance only

Adoption not part of the score

2538 stars · 184 forks observed · 2026-08-28

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-30, confidence not recorded

Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go. It extends Kafka consumer groups by binding persistent state tables to them, enabling scalable and fault-tolerant microservices with at-least-once delivery semantics.

Use cases

• process kafka streams in go
• build stateful kafka microservices
• scale stream processing across instances
• persist processing state in kafka
• monitor kafka stream processors via web ui
• handle kafka messages with callback functions
• build fault-tolerant event-driven services

When to choose

• you need distributed stream processing on kafka in go
• you want state tables persisted in kafka with automatic rebalancing
• you need fault tolerance and at-least-once semantics out of the box
• you want built-in monitoring and introspection of processor state

When to avoid

• you use a message broker other than kafka
• you need exactly-once processing semantics
• you work outside the go ecosystem
• you need complex sql-based stream transformations

Facets

library · maturity active

streaming message-queue microservices middleware monitoring microservices backend go windows cross-platform kafka stream-processing consumer-groups stateful-processing event-driven at-least-once sarama messaging data-engineering linux macos

Member repositories

For agents

markdown · JSON · MCP: product_card(name="lovoo/goka")