franz-go

Replicate and sync Kafka topics between clusters in realtime. Supports topic re-mapping, healthchecks, and hot failovers for high availability.

A simple notification system with live notification streaming powered by Kafka

Kafka-to-Kafka replication built on franz-go, with a web dashboard, REST API, CLI and role-based access. Runs locally or in Docker.

Key-value reads over Redpanda/Kafka compacted topics: a pure-Go sidecar indexing key -> (partition, offset) in Pebble, serving values straight from the log. Zero value duplication.

Go library for monitoring Apache Kafka consumer health and detects stalled consumers

Kafka → TigerBeetle: a sink for applying financial commands from a stream, with poison/reject/infrastructure handling and DLQ — plus CDC back out.

Lightweight Kafka wrapper for Go, built on franz-go. Simplifies batch consumption, Share Groups, transactions, exactly-once processing (EOS), and observability.

Preview what a Kafka consumer-group offset reset would do: reprocess/skip counts per partition, without committing anything.

Event ingest API for Nine. HTTP and gRPC, API-key auth, per-tenant rate limiting.

An example using Tansu with the Franz Go Client

Event ticketing platform in Go: franz-go Kafka library (retry/DLQ), Redis distributed locks against double-booking

A resilient market data aggregation pipeline written in Go