kafka

There are 12428 repositories under kafka topic.

  • go-zero-looklook

    🔥基于go-zero(go zero) 微服务全技术栈开发最佳实践项目。Develop best practice projects based on the full technology stack of go zero (go zero) microservices.

    Language:Go4.5k
  • ockam

    ockam

    Orchestrate end-to-end encryption, cryptographic identities, mutual authentication, and authorization policies between distributed applications – at massive scale.

    Language:Rust4.5k

  • spec

    The AsyncAPI specification allows you to create machine-readable definitions of your asynchronous APIs.

    Language:JavaScript4.4k

  • pipeline

    PipelineAI

    Language:Jsonnet4.2k
  • automq

    automq

    AutoMQ is a cloud-first alternative to Kafka by decoupling durability to S3 and EBS. 10x Cost-Effective. No Cross-AZ Traffic Cost. Autoscale in seconds. Single-digit ms latency.

    Language:Java4k

  • arroyo

    Distributed stream processing engine in Rust

    Language:Rust3.9k
  • console

    console

    Redpanda Console is a developer-friendly UI for managing your Kafka/Redpanda workloads. Console gives you a simple, interactive approach for gaining visibility into your topics, masking data, managing consumer groups, and exploring real-time data with time-travel debugging.

    Language:TypeScript3.9k

  • kafkajs

    A modern Apache Kafka client for node.js

    Language:JavaScript3.8k

  • gizmo

    A Microservice Toolkit from The New York Times

    Language:Go3.8k

  • Alink

    Alink is the Machine Learning algorithm platform based on Flink, developed by the PAI team of Alibaba computing platform.

    Language:Java3.6k
  • akhq

    akhq

    Kafka GUI for Apache Kafka to manage topics, topics data, consumers group, schema registry, connect and more...

    Language:Java3.4k

  • kafka-stack-docker-compose

    docker compose files to create a fully working kafka stack

    Language:Shell3.3k

  • faststream

    FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.

    Language:Python3.3k

  • surging

    Surging is a micro-service engine that provides a lightweight, high-performance, modular RPC request pipeline. support Event-based Asynchronous Pattern and reactive programming ,The service engine supports http, TCP, WS,Grpc, Thrift,Mqtt, UDP, and DNS protocols. It uses ZooKeeper and Consul as a registry, and integrates it. Hash, random, polling, Fair Polling as a load balancing algorithm, built-in service governance to ensure reliable RPC communication, the engine contains Diagnostic, link tracking for protocol and middleware calls, and integration SkyWalking Distributed APM

    Language:C#3.2k
  • EFAK

    EFAK

    A easy and high-performance monitoring system, for comprehensive monitoring and management of kafka cluster.

    Language:Java3.1k

  • netty-learning-example

    :egg: Netty实践学习案例，见微知著！带着你的心，跟着教程。我相信你行欧。

    Language:Java2.9k

  • qmq

    QMQ是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景； 也包括报价搜索等高吞吐量场景。

    Language:Java2.8k
  • cruise-control

    cruise-control

    Cruise-control is the first of its kind to fully automate the dynamic workload rebalance and self-healing of a Kafka cluster. It provides great value to Kafka users by simplifying the operation of Kafka clusters.

    Language:Java2.8k

  • BigDataGuide

    大数据学习，从零开始学习大数据，包含大数据学习各阶段学习视频、面试资料

    2.8k
  • memgraph

    memgraph

    Open-source graph database, tuned for dynamic analytics environments. Easy to adopt, scale and own.

    Language:C++2.5k

  • svix-webhooks

    The enterprise-ready webhooks service 🦀

    Language:Rust2.5k

  • Java-Interview

    「Java面试小抄」一份通向理想互联网公司的面试汇总，包括 Java基础、Java并发、JVM、MySQL、Redis、Spring、MyBatis、Kafka、计算机操作系统、计算机网络、系统设计、分布式、Java 项目实战等

    2.5k

  • goka

    Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.

    Language:Go2.4k
  • peerdb

    peerdb

    Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage

    Language:Go2.3k
  • SZT-bigdata

    SZT-bigdata

    深圳地铁大数据客流分析系统🚇🚄🌟

    Language:Scala2.3k

  • vanus

    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.

    Language:Go2.3k

  • kubeblocks

    KubeBlocks is an open-source control plane software that runs and manages databases, message queues and other stateful applications on K8s.

    Language:Go2.3k

  • schema-registry

    Confluent Schema Registry for Kafka

    Language:Java2.2k

  • kafka_exporter

    Kafka exporter for Prometheus

    Language:Go2.2k

  • enqueue-dev

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

    Language:PHP2.2k

  • syslog-ng

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

    Language:C2.2k

  • Practical.CleanArchitecture

    Full-stack .Net 8 Clean Architecture (Microservices, Modular Monolith, Monolith), Blazor, Angular 19, React 18, Vue 3, BFF with YARP, Domain-Driven Design, CQRS, SOLID, Asp.Net Core Identity Custom Storage, OpenID Connect, Entity Framework Core, OpenTelemetry, SignalR, Hosted Services, Health Checks, Rate Limiting, Cloud Services (Azure, AWS, GCP).

    Language:C#2.2k

  • node-rdkafka

    Node.js bindings for librdkafka

    Language:JavaScript2.1k

  • plumber

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

    Language:Go2.1k

  • karafka

    Ruby and Rails efficient Kafka processing framework

    Language:Ruby2.1k
  • php-rdkafka

    php-rdkafka

    Production-ready, stable Kafka client for PHP

    Language:C2.1k