Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
Repository Index
47,133 repositories indexed
1–18 of 18 · Most stars
Sarama is a Go library for Apache Kafka.
Building event-driven applications the easy way in Go.
Fancy stream processing made operationally mundane
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
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 💻
Enterprise Network Flow Collector (IPFIX, sFlow, Netflow)
Conduit streams data between data stores. Kafka Connect replacement. No JVM required.
This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)
A CLI tool for Kafka
The type-safe, event-driven workflow orchestration library that scales with your business. Build robust, distributed workflows in Go with compile-time safety, automatic retries, and horizontal scaling out of the box. Integrate with your existing tech stack using adapters 🚀
A kafka command line browser
k6 extension to load test Apache Kafka with support for various serialization formats, SASL, TLS, compression, Schema Registry client and beyond
Build systems with Go examples
Stream database events from PostgreSQL to Kafka
☝️ go-graphql subscription over Kafka/Redis/NSQ example
A production-grade messaging abstraction for Go. It provides a unified API to decouple business logic from various brokers including Kafka, RabbitMQ, RocketMQ, NATS, Redis, and AWS SQS. Featuring built-in OpenTelemetry integration and engineered for high reliability.