Memphis.dev is a highly scalable and effortless data streaming platform

Strimzi canary

High-performance and efficient Framework and Agent for creating data pipelines. The core of pipeline descriptions is based on the Configuration As Code concept and the Pkl configuration language by Apple.

This project offers a peer-to-peer content-addressable distributed file storage in Go with a peer-to-peer library built on top of TCP from scratch. It also supports data encryption during storage and transmission

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

This project offers a peer-to-peer content-addressable distributed file storage in Go with a peer-to-peer library built on top of TCP from scratch. It also supports data encryption during storage and transmission

Next-Generation Real-Time Data Processing Platform

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).

Real-time data streaming API in Go, integrating Kafka, Prometheus metrics, and middleware for scalable, low-latency applications with robust monitoring and benchmarking.

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.

Package longpoll supports batching e.g. receiving as many values as possible from a channel.