Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.

Sarama is a Go library for Apache Kafka.

The API traffic analyzer for Kubernetes providing real-time K8s protocol-level visibility, capturing and monitoring all traffic and payloads going in, out and across containers, pods, nodes and clusters. Inspired by Wireshark, purposely built for Kubernetes

Fancy stream processing made operationally mundane

Kafka library in Go

Building event-driven applications the easy way in Go.

Kafka implemented in Golang with built-in coordination (No ZK dep, single binary install, Cloud Native)

🔥基于go-zero(go zero) 微服务全技术栈开发最佳实践项目。Develop best practice projects based on the full technology stack of go zero (go zero) microservices.

A Microservice Toolkit from The New York Times

Redpanda Console is a developer-friendly UI for managing your Kafka/Redpanda workloads. Console gives you a simple, interactive approach for gaining visibility into your topics, masking data, managing consumer groups, and exploring real-time data with time-travel debugging.

Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.

Vanus is a Serverless, event streaming system with processing capabilities. It easily connects SaaS, Cloud Services, and Databases to help users build next-gen Event-driven Applications.

A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems.

Kafka exporter for Prometheus

This repo contains my notes on working with Go and computer systems.

Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage

A lightweight stream processing library for Go

KubeBlocks is an open-source control plane that runs and manages databases, message queues and other data infrastructure on K8s.

Event Sourcing for Go!

franz-go contains a feature complete, pure Go library for interacting with Kafka from 0.8.0 through 3.6+. Producing, consuming, transacting, administrating, etc.