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

Building event-driven applications the easy way in Go.

Kafka library 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

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.

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

Kafka exporter for Prometheus

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

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

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

A lightweight stream processing library for Go

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

Event Sourcing for Go!

Test your code without writing mocks with ephemeral Docker containers 📦 Setup popular services with just a couple lines of code ⏱️ No bash, no yaml, only code 💻