kafka

Full-stack .Net 10 Clean Architecture (Microservices, Modular Monolith, Monolith), Blazor, Angular 22, React 19, Vue 3.5, BFF with YARP, NextJs 16, Domain-Driven Design, CQRS, SOLID, Asp.Net Core Identity Custom Storage, OpenID Connect, EF Core, OpenTelemetry, SignalR, Background Services, Health Checks, Rate Limiting, Clouds (Azure, AWS, GCP), ...

syslog-ng is an enhanced log daemon, supporting a wide range of input and output methods: syslog, unstructured text, queueing, SQL & NoSQL.

High-performance log ingestion and ETL engine

Flow collector, enricher and visualizer

Ruby and Rails efficient Kafka processing framework

Metering and Billing for AI, API and DevOps. Collect and aggregate millions of usage events in real-time and enable usage-based billing.

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

Node.js bindings for librdkafka

Postgres change data capture to streams, queues, and search indexes like Kafka, SQS, Elasticsearch, HTTP endpoints, and more

Production-ready, stable Kafka client for PHP

A lightweight stream processing library for Go

A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems.

Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.

✍️ Java 工程师必备架构体系知识总结：涵盖分布式、微服务、RPC等互联网公司常用架构，以及数据存储、缓存、搜索等必备技能

Kafka Docker for development. Kafka, Zookeeper, Schema Registry, Kafka-Connect, , 20+ connectors

Apache Kafka, Apache Flink and Confluent Platform examples and demos

A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka

Java生态研究(Spring Boot + Redis + Dubbo + RocketMQ + Elasticsearch)🔥🔥🔥🔥🔥

This repo contains my notes on working with Go and computer systems.

🦭 Distributed log streaming engine built from first principles

Python Stream Processing. A Faust fork

High-performance multi-data-source database client — ~30MB, AI & MCP ready, zero Electron bloat. | 高性能多数据源数据库客户端：约 30MB，AI 与 MCP 就绪，告别 Electron 膨胀。

Secor is a service implementing Kafka log persistence

大数据知识仓库涉及到数据仓库建模、实时计算、大数据、数据中台、系统设计、Java、算法等。

前端性能监控系统,消息队列,高可用,集群等相关架构

Communication infrastructure for the AI era — one binary, one broker, one storage layer, any protocol

🦎 A lightweight, multi-protocol gateway for event-driven applications and AI agents. Expose and govern Kafka, MQTT, APIs, and MCP through one high-performance engine with shared routing, security, schema, and observability.

More than 2000+ Data engineer interview questions.

Vanus is a Serverless, event streaming system with processing capabilities. It easily connects SaaS, Cloud Services, and Databases to help users build next-gen Event-driven Applications.

Event Sourcing for Go!