Kafka

Zipkinopenzipkin/zipkin

A distributed tracing system that collects and queries timing data to troubleshoot latency problems in microservices.

MeterSpheremetersphere/metersphere

An open-source continuous testing platform with AI assistant, integrating test management, API testing, and team collaboration.

DataHubdatahub-project/datahub

An open-source metadata platform for data discovery, governance, and observability across your entire data and AI stack.

Centrifugocentrifugal/centrifugo

A scalable, language-agnostic real-time messaging server for building chat apps, live features, and collaborative tools.

MassTransitMassTransit/MassTransit

A free, open-source distributed application framework for .NET that enables message-based, loosely-coupled asynchronous communication.

CAPdotnetcore/CAP

A .NET library for distributed transactions and event bus integration in microservices using the Outbox pattern.

MISPMISP/MISP

An open-source platform for collecting, storing, sharing, and acting upon cybersecurity threat intelligence and indicators.

CDSovh/cds

An enterprise-grade continuous delivery and DevOps automation platform written in Go, featuring workflow-as-code and multi-cloud scalability.

Seldon CoreSeldonIO/seldon-core

An MLOps framework to package, deploy, monitor, and manage thousands of production machine learning models on Kubernetes.

Event Sourcing .NEToskardudycz/EventSourcing.NetCore

A comprehensive collection of tutorials, samples, and resources for implementing Event Sourcing and CQRS in .NET using Marten and EventStoreDB.

Light-4Jnetworknt/light-4j

A fast, lightweight, cloud-native microservices framework for Java with built-in cross-cutting concerns.

Light-4jnetworknt/light-4j

A fast, lightweight, cloud-native microservices framework for Java with built-in cross-cutting concerns.

Crowd.devCrowdDotDev/crowd.dev

An open-source platform that collects, unifies, and analyzes community data to provide a 360-degree view of developer engagement.

spongezhufuyi/sponge

A Go development framework with a low-code approach for building backend services, microservices, and APIs through automated code generation.

Practical.CleanArchitecturephongnguyend/Practical.CleanArchitecture

A full-stack .NET 10 reference application demonstrating Clean Architecture with support for monoliths, modular monoliths, and microservices.

EasyCachingdotnetcore/EasyCaching

An open-source caching library for .NET Core that simplifies basic and advanced caching operations with multiple provider support.

Secorpinterest/secor

A fault-tolerant service that persists Kafka log data to cloud storage like S3, GCS, Azure Blob Storage, and OpenStack Swift.

jvm-profileruber-common/jvm-profiler

A Java Agent for distributed JVM profiling, collecting metrics and tracing methods for Hadoop/Spark applications.

HiBenchintel-hadoop/HiBench

A comprehensive benchmark suite for evaluating speed, throughput, and resource utilization of big data frameworks like Hadoop, Spark, and streaming engines.

comqttwind-c/comqtt

A lightweight, high-performance, embeddable MQTT broker server written in Go, supporting distributed clusters and MQTT v3.0, v3.1.1, and v5.0.

Mobius: C# API for SparkMicrosoft/Mobius

C# and F# language binding and extensions for Apache Spark, enabling .NET developers to write Spark driver programs and data processing operations.

camuslinkedin/camus

LinkedIn's previous generation Kafka to HDFS pipeline for batch data ingestion.

Heroicspotify/heroic

A scalable time series database built on Bigtable, Cassandra, and Elasticsearch for high-volume metrics.

SlimMessageBuszarusz/SlimMessageBus

A lightweight, extensible messaging framework for .NET supporting pub/sub and request-response patterns with multiple broker integrations.

Zigguratgojek/ziggurat

A Clojure framework for building stateless stream processing applications on Kafka with built-in retry mechanisms.

Sentry Relaygetsentry/relay

A proxy service that offloads event processing, normalization, and ingestion from Sentry SDKs and server.

WowAhoo-Wang/Wow

A Kotlin/Java framework for building reactive, event-sourced microservices using DDD and CQRS patterns.

tcpdogmehrdadrad/tcpdog

eBPF-based tool for efficient TCP observability, exporting kernel-level socket statistics to Elasticsearch, ClickHouse, or InfluxDB.

workflowluno/workflow

A type-safe, event-driven workflow orchestration library for building robust, distributed workflows in Go with compile-time safety and horizontal scaling.

Actionbasekakao/actionbase

A specialized database for social interactions (likes, views, follows) that precomputes data at write time for real-time, high-scale reads.

SchedulerPagerDuty/scheduler

A fault-tolerant Scala library for scheduling arbitrary code to run at arbitrary times across distributed systems.

samza-luwakromseygeek/samza-luwak

An experimental integration of Apache Samza and Luwak for scalable real-time document matching against large query sets.

Map/Reduce implementations of common ML algorithmsYannael/BigDataAnalytics_INFOH515

Jupyter notebooks for hands-on Big Data Analytics exercise classes covering Spark ML, Map/Reduce algorithms, and deep learning.

psql-streamerblind-oracle/psql-streamer

Streams PostgreSQL database events to Kafka using logical replication and can also consume events from Kafka.

dropwizard-zipkinsmoketurner/dropwizard-zipkin

A Dropwizard bundle for sending distributed tracing data to Zipkin using Brave.

kafkacyngn/vertx-kafka

A Vert.x library for asynchronous Kafka message consumption and production via the Vert.x event bus.