Topic

kafka

Repositories (1207)

kafkaflow
kafkaflow Farfetch C#

Apache Kafka .NET Framework to create applications simple to use and extend.

744
Full-Stack-Notes
Full-Stack-Notes heibaiying Java

全栈工程师手册

734
goflow
goflow cloudflare Go

The high-scalability sFlow/NetFlow/IPFIX collector used internally at Cloudflare.

730
Echo
Echo Veal98 JavaScript

🦄 论坛:基于 SpringBoot + MyBatis + MySQL + Redis + Kafka + Elasticsearch + Spring Security + ... 并提供详细的开发文档和配套教程。包含帖子、评论、私...

730
hstream
hstream hstreamdb Haskell

HStreamDB is an open-source, cloud-native streaming database for IoT and beyond. Modernize your data stack for real-time applications.

727
kafka-storm-starter
kafka-storm-starter miguno Scala

[PROJECT IS NO LONGER MAINTAINED] Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while...

724
JavaFamily
JavaFamily chenjiabing666 Java

【Java面试+Java学习指南】 一份涵盖大部分Java程序员所需要掌握的核心知识。

717
jafka
jafka adyliu Java

a fast and simple distributed publish-subscribe messaging system (mq)

714
bitnami-docker-kafka
bitnami-docker-kafka bitnami Shell

Bitnami Docker Image for Kafka

705
mendmix-cloud
mendmix-cloud dromara Java

Mendmix定位是一站式分布式开发架构开源解决方案及云原生架构技术底座。Mendmix提供了数据库、缓存、消息中间件、分布式定时任务、安全框架、网关以及主流产商云...

704
kafka-connect-elasticsearch
kafka-connect-elasticsearch confluentinc Java

Kafka Connect Elasticsearch connector

701
koperator
koperator banzaicloud Go

Oh no! Yet another Apache Kafka operator for Kubernetes

700
nussknacker
nussknacker TouK Scala

Low-code tool for automating actions on real time data | Stream processing for the users.

699
cp-all-in-one
cp-all-in-one confluentinc Python

docker-compose.yml files for cp-all-in-one , cp-all-in-one-community, cp-all-in-one-cloud, Apache Kafka Confluent Platform

697
brod
brod kafka4beam Erlang

Apache Kafka client library for Erlang/Elixir

669
kafka-lag-exporter
kafka-lag-exporter seglo Scala

Monitor Kafka Consumer Group Latency with Kafka Lag Exporter

659
laravel-kafka
laravel-kafka mateusjunges PHP

Use Kafka Producers and Consumers in your laravel app with ease!

656
transfer
transfer artie-labs Go

Database replication platform that leverages change data capture. Stream production data from databases to your data warehouse (Snowflake, BigQuery, R...

655
Real-time-stock-market-prediction
Real-time-stock-market-prediction victor369basu JavaScript

In this repository, I have developed the entire server-side principal architecture for real-time stock market prediction with Machine Learning. I have...

645
NetDiscovery
NetDiscovery fengzhizi715 Java

NetDiscovery 是一款基于 Vert.x、RxJava 2 等框架实现的通用爬虫框架/中间件。

643
datafaker
datafaker gangly Python

Datafaker is a large-scale test data and flow test data generation tool. Datafaker fakes data and inserts to varied data sources. 测试数据生成工具

639
DoctorK
DoctorK pinterest Java

DoctorK is a service for Kafka cluster auto healing and workload balancing

632
zilla
zilla aklivity Java

🦎 A multi-protocol edge & service proxy. Seamlessly interface web apps, IoT clients, & microservices to Apache Kafka® via declaratively defined, stat...

629
Zenko
Zenko scality Gherkin

Zenko is the open source multi-cloud data controller: own and keep control of your data on any cloud.

620
freestyle
freestyle frees-io Scala

A cohesive & pragmatic framework of FP centric Scala libraries

614
all-things-cqrs
all-things-cqrs ddd-by-examples Java

Comprehensive guide to a couple of possible ways of synchronizing two states with Spring tools. Synchronization is shown by separating command and que...

604
reactive-interaction-gateway
reactive-interaction-gateway Accenture Elixir

Create low-latency, interactive user experiences for stateless microservices.

604
kafka_ex
kafka_ex kafkaex Elixir

Kafka client library for Elixir

599
WeDataSphere
WeDataSphere WeBankFinTech

WeDataSphere is a financial grade, one-stop big data platform suite.

596
SuperSafeBank
SuperSafeBank mizrael C#

Sample Event Sourcing implementation with .NET Core

593
components-contrib
components-contrib dapr Go

Community driven, reusable components for distributed apps

581
SlimMessageBus
SlimMessageBus zarusz C#

Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.

578
spring-boot-study
spring-boot-study hemin1003 Java

SpringBoot框架源码实战(已更新到springboot2版本实现)~基本用法,Rest,Controller,事件监听,连接数据库MySQL,jpa,redis集成,mybatis集成(声明式与xml...

568
kq
kq joowani Python

Kafka-based Job Queue for Python

558
venice
venice linkedin Java

Venice, Derived Data Platform for Planet-Scale Workloads.

542
dnc
dnc dncto C#

dnc 去中心化 开源社区 轻联盟 dncto.com QQ群 779699538

541
awesome-kafka
awesome-kafka infoslack

A list about Apache Kafka

539
my-moments
my-moments amrkhaledccd Java

Instagram Clone - Cloning Instagram for learning purpose

538
cppkafka
cppkafka mfontanini C++

Modern C++ Apache Kafka client library (wrapper for librdkafka)

530
sparta
sparta Stratio Scala

Real Time Analytics and Data Pipelines based on Spark Streaming

528
hypertrace
hypertrace hypertrace Shell

An open source distributed tracing & observability platform

520
spiderman
spiderman TurboWay Python

基于 scrapy-redis 的通用分布式爬虫框架

516
kafka-connect-ui
kafka-connect-ui lensesio JavaScript

Deprecated - See Lenses.io Community Edition

515
kafka-map
kafka-map dushixiang JavaScript

A beautiful, concise and powerful kafka web management tool. 一个美观简洁且强大的kafka web管理工具。

508
kminion
kminion redpanda-data Go

KMinion is a feature-rich Prometheus exporter for Apache Kafka written in Go. It is lightweight and highly configurable so that it will meet your requ...

507
Propan
Propan Lancetnik Python

Propan is a powerful and easy-to-use Python framework for building event-driven applications that interact with any MQ Broker

502
hangout
hangout childe Java

用java实现一下Logstash的几个常用input/filter/output, 希望能有效率上面的大提升. 现在我们迁移到golang了 https://github.com/childe/gohangout

501
SpringBoot-Learning
SpringBoot-Learning liaozihong Java

基于Gradle构建,使用SpringBoot在各个场景的应用,包括集成消息中间件、前后端分离、数据库、缓存、分布式锁、分布式事务等

501
micronaut-microservices-poc
micronaut-microservices-poc asc-lab Java

Very simplified insurance sales system made in a microservices architecture using Micronaut

494
xichuan_note
xichuan_note Raray-chuan Java

xichuan的学习总结笔记,覆盖了java、spring、java其他常用框架,以及大数据相关组件等📚

488