kafka

There are 14147 repositories under kafka topic.

  • pathway

    pathwaycom/pathway

    Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.

    Language:Python43.4k881021.3k

  • DataTalksClub/data-engineering-zoomcamp

    Data Engineering Zoomcamp is a free nine-week course that covers the fundamentals of data engineering.

    Language:Jupyter Notebook32.7k5281366.9k

  • apache/kafka

    Mirror of Apache Kafka

    Language:Java30.9k1.1k014.6k

  • yudaocode/SpringBoot-Labs

    一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024

    Language:Java19.9k807456.1k
  • thingsboard

    thingsboard/thingsboard

    Open-source IoT Platform - Device management, data collection, processing and visualization.

    Language:Java19.7k5727.6k5.8k

  • heibaiying/BigData-Notes

    大数据入门指南 :star:

    Language:Java16.6k448424.3k

  • influxdata/telegraf

    Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.

    Language:Go16.2k3068.1k5.7k
  • flink-learning

    zhisheng17/flink-learning

    flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

    Language:Java14.9k51504k

  • aalansehaiyang/technology-talk

    【大厂面试专栏】一份Java程序员需要的技术指南，这里有面试题、系统架构、职场锦囊、主流中间件等，让你成为更牛的自己！

    14.6k843143.8k

  • sogou/workflow

    C++ Parallel Computing and Asynchronous Networking Framework

    Language:C++14k2406862.5k

  • IBM/sarama

    Sarama is a Go library for Apache Kafka.

    Language:Go12.2k6501.4k1.8k

  • yahoo/CMAK

    CMAK is a tool for managing Apache Kafka clusters

    Language:Scala11.9k5256882.5k

  • debezium/debezium

    Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.

    Language:Java11.8k21402.7k
  • kubeshark

    kubeshark/kubeshark

    The API traffic analyzer for Kubernetes providing real-time K8s protocol-level visibility, capturing and monitoring all traffic and payloads going in, out and across containers, pods, nodes and clusters. Inspired by Wireshark, purposely built for Kubernetes

    Language:Go11.5k71349498
  • kafka-ui

    provectus/kafka-ui

    Open-Source Web UI for Apache Kafka Management

    Language:Java11.3k741.8k1.3k
  • redpanda

    redpanda-data/redpanda

    Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!

    Language:C++11k13811.6k674

  • wangzhiwubigdata/God-Of-BigData

    专注大数据学习面试，大数据成神之路开启。Flink/Spark/Hadoop/Hbase/Hive...

    10.3k33103.2k
  • watermill

    ThreeDotsLabs/watermill

    Building event-driven applications the easy way in Go.

    Language:Go8.9k85239458
  • connect

    redpanda-data/connect

    Fancy stream processing made operationally mundane

    Language:Go8.4k1191.5k887
  • risingwave

    risingwavelabs/risingwave

    Real-time event streaming platform. Streaming CDC, stream processing, low-latency serving, and Iceberg management.

    Language:Rust8.3k827.4k677

  • segmentio/kafka-go

    Kafka library in Go

    Language:Go8.3k88772829

  • Graylog2/graylog2-server

    Free and open log management

    Language:Java7.8k2388k1.1k
  • KnowStreaming

    didi/KnowStreaming

    一站式云原生实时流数据平台，通过0侵入、插件化构建企业级Kafka服务，极大降低操作、存储和管理实时流数据门槛

    Language:Java7.1k1146541.3k

  • HariSekhon/DevOps-Bash-tools

    1000+ DevOps Bash Scripts - AWS, GCP, Kubernetes, Docker, CI/CD, APIs, SQL, PostgreSQL, MySQL, Hive, Impala, Kafka, Hadoop, Jenkins, GitHub, GitLab, BitBucket, Azure DevOps, TeamCity, Spotify, MP3, LDAP, Code/Build Linting, pkg mgmt for Linux, Mac, Python, Perl, Ruby, NodeJS, Golang, Advanced dotfiles: .bashrc, .vimrc, .gitconfig, .screenrc, tmux..

    Language:Shell7.1k93111.3k
  • automq

    AutoMQ/automq

    AutoMQ is a diskless Kafka® on S3. 10x Cost-Effective. No Cross-AZ Traffic Cost. Autoscale in seconds. Single-digit ms latency. Multi-AZ Availability.

    Language:Java7k51555489

  • dotnetcore/CAP

    Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern

    Language:C#6.9k3031.3k1.3k

  • robinhood/faust

    Python Stream Processing

    Language:Python6.8k137477535

  • CoderLeixiaoshuai/java-eight-part

    『Java八股文』Java面试套路，Java进阶学习，打破内卷拿大厂Offer，升职加薪！

    Language:Java6.8k5471k

  • apache/flink-cdc

    Flink CDC is a streaming data integration tool

    Language:Java6.2k1361.7k2.1k
  • materialize

    MaterializeInc/materialize

    Real-time Data Integration and Transformation: use SQL to transform, deliver, and act on fast-changing data.

    Language:Rust6.1k710478

  • obsidiandynamics/kafdrop

    Kafka Web UI

    Language:Java6k62346880

  • opengoofy/hippo4j

    📌 异步线程池框架，支持线程池动态变更&监控&报警，无需修改代码轻松引入。Asynchronous thread pool framework, support Thread Pool Dynamic Change & monitoring & Alarm, no need to modify the code easily introduced.

    Language:Java5.9k776931.2k

  • dpkp/kafka-python

    Python client for Apache Kafka

    Language:Python5.8k1431.5k1.4k

  • rfyiamcool/share_ppt

    🚗 个人做过的技术分享... ( topic: 高性能架构, 中间件原理实践，云原生，Golang 等)

    5.7k25233989
  • strimzi-kafka-operator

    strimzi/strimzi-kafka-operator

    Apache Kafka® running on Kubernetes

    Language:Java5.4k952.8k1.4k

  • 2227324689/gpmall

    【咕泡学院实战项目】-基于SpringBoot+Dubbo构建的电商平台-微服务架构、商城、电商、微服务、高并发、kafka、Elasticsearch

    Language:Java5k203501.9k