A lightweight stream processing library for Go

Probabilistic data structures for processing continuous, unbounded streams.

A stream processing API for Go (alpha)

Conduit streams data between data stores. Kafka Connect replacement. No JVM required.

Event Based Applications [DEPRECATED]

Library to connect to the Azure Event Hub via AMQP 1.0 for the Go programming language (Golang) based on Apache Qpid Proton (an AMQP 1.0 C library)

Light-weight event-processing based on the idea of meshed cells with different pluggable behaviors

A Go library that exposes executors, interfaces, data structures, and utility functions which combined a universal stream processor, invariant to any specific messaging system.

Schema Registry is a product used for schema management and message validation.

Data stream library with kinesis

Persistor is a product used for permanent data storage. It provides support for multiple cloud platforms, more specifically the Google Cloud Platform and Microsoft Azure, as well as for various broker types (GCP PubSub, Azure Service Bus and Kafka) and different kinds of storage services (Google Cloud Storage and Azure Blob Storage).

lib-brokers is a Go library which contains the interfaces used to interact with messaging systems without relying on a specific technology or client library. This library attempts to solve the issue of properly abstracting away the interaction between applications and messaging systems.