Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
- telegraf
- monitoring
- time-series
- metrics
Repository Index
47,133 repositories indexed
1–20 of 20 · Most stars
Sarama is a Go library for Apache Kafka.
- kafka
- kafka-client
- go
Building event-driven applications the easy way in Go.
- watermill
- event-driven
- event-sourcing
- sagas
Fancy stream processing made operationally mundane
- message-queue
- stream-processing
- streaming-data
- message-bus
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
- etl
- sql
- bigquery
- cloud-native
Kafka-style message streaming in Go. Built on NATS. Single binary, no JVM, no ZooKeeper.
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 💻
- go
- golang
- testing
- integration-testing
Enterprise Network Flow Collector (IPFIX, sFlow, Netflow)
- network
- ipfix
- sflow
- golang
Conduit streams data between data stores. Kafka Connect replacement. No JVM required.
- go
- data-integration
- etl
- data-pipeline
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 🚀
- eventdrivenarchitecture
- golang
- kafka
- reflex
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
- golang
- go
- book
- programming-language
A Kafka log inspired in-memory and append-only data structure
Stream database events from PostgreSQL to Kafka
- postgresql
- events
- stream
- 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.