Stream JsonThe micro-library of Node.js stream components for creating custom JSON processing pipelines with a minimal memory footprint. It can parse JSON files far exceeding available memory streaming individual primitives using a SAX-inspired API.
Stars: ✭ 462 (+477.5%)
distogramA library to compute histograms on distributed environments, on streaming data
Stars: ✭ 19 (-76.25%)
KaliumKalium: a reactive framework for micro-services
Stars: ✭ 53 (-33.75%)
daggerDagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.
Stars: ✭ 238 (+197.5%)
GoflowThe high-scalability sFlow/NetFlow/IPFIX collector used internally at Cloudflare.
Stars: ✭ 460 (+475%)
WormholeWormhole is a SPaaS (Stream Processing as a Service) Platform
Stars: ✭ 863 (+978.75%)
HazelcastOpen-source distributed computation and storage platform
Stars: ✭ 4,662 (+5727.5%)
KafkawizeKafkawize : A Self service Apache Kafka Topic Management tool/portal. A Web application which automates the process of creating and browsing Kafka topics, acls, schemas by introducing roles/authorizations to users of various teams of an org.
Stars: ✭ 79 (-1.25%)
twitterstreamTwitter Streaming API Example with Kafka Streams in Scala
Stars: ✭ 49 (-38.75%)
JockoKafka implemented in Golang with built-in coordination (No ZK dep, single binary install, Cloud Native)
Stars: ✭ 4,445 (+5456.25%)
kafka-jdbc-connectorSimple way to copy data from relational databases into kafka.
Stars: ✭ 19 (-76.25%)
Bigdata Interview🎯 🌟[大数据面试题]分享自己在网络上收集的大数据相关的面试题以及自己的答案总结.目前包含Hadoop/Hive/Spark/Flink/Hbase/Kafka/Zookeeper框架的面试题知识总结
Stars: ✭ 857 (+971.25%)
God Of Bigdata专注大数据学习面试,大数据成神之路开启。Flink/Spark/Hadoop/Hbase/Hive...
Stars: ✭ 6,008 (+7410%)
BrooklinAn extensible distributed system for reliable nearline data streaming at scale
Stars: ✭ 668 (+735%)
connectCLI tool and Go client library for the Kafka Connect REST API
Stars: ✭ 45 (-43.75%)
ReDeA Redis dehydrator module
Stars: ✭ 63 (-21.25%)
Spring Boot StudySpringBoot框架源码实战(已更新到springboot2版本实现)~基本用法,Rest,Controller,事件监听,连接数据库MySQL,jpa,redis集成,mybatis集成(声明式与xml两种方式~对应的添删查改功能),日志处理,devtools配置,拦截器用法,资源配置读取,测试集成,Web层实现请求映射,security安全验证,rabbitMq集成,kafka集成,分布式id生成器等。项目实战:https://github.com/hemin1003/yfax-parent 已投入生产线上使用
Stars: ✭ 440 (+450%)
postgres-kafka-demoFully reproducible, Dockerized, step-by-step, demo on how to stream tables from Postgres to Kafka/KSQL back to Postgres. Detailed blog post published on Medium.
Stars: ✭ 128 (+60%)
VectorA reliable, high-performance tool for building observability data pipelines.
Stars: ✭ 8,736 (+10820%)
xlstreamTurns XLSX into a readable stream.
Stars: ✭ 148 (+85%)
Real Time Stock Market PredictionIn this repository, I have developed the entire server-side principal architecture for real-time stock market prediction with Machine Learning. I have used Tensorflow.js for constructing ml model architecture, and Kafka for real-time data streaming and pipelining.
Stars: ✭ 414 (+417.5%)
Springwolf CoreAutomated documentation for async APIs built with Spring Boot
Stars: ✭ 63 (-21.25%)
Every Single Day I TldrA daily digest of the articles or videos I've found interesting, that I want to share with you.
Stars: ✭ 249 (+211.25%)
CppkafkaModern C++ Apache Kafka client library (wrapper for librdkafka)
Stars: ✭ 413 (+416.25%)
Kafka Connect Mq SourceThis repository contains a Kafka Connect source connector for copying data from IBM MQ into Apache Kafka.
Stars: ✭ 57 (-28.75%)
HermesFast and reliable message broker built on top of Kafka.
Stars: ✭ 665 (+731.25%)
keralaDistributed KV Streams
Stars: ✭ 16 (-80%)
Awesome Recommendation EngineThe purpose of this tiny project is to put things together with the know how that i learned from the course big data expert from formacionhadoop.com The idea is to show how to play with apache spark streaming, kafka,mongo, spark machine learning algorithms.
Stars: ✭ 47 (-41.25%)
KmqKafka-based message queue
Stars: ✭ 239 (+198.75%)
StoragetapperStorageTapper is a scalable realtime MySQL change data streaming, logical backup and logical replication service
Stars: ✭ 232 (+190%)
Devops Bash Tools550+ DevOps Bash Scripts - AWS, GCP, Kubernetes, Kafka, Docker, APIs, Hadoop, SQL, PostgreSQL, MySQL, Hive, Impala, Travis CI, Jenkins, Concourse, 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.conf, .psqlrc ...
Stars: ✭ 226 (+182.5%)
GnomockTest your code without writing mocks with ephemeral Docker containers 📦 Setup popular services with just a couple lines of code ⏱️ No bash, no yaml, only code 💻
Stars: ✭ 398 (+397.5%)
Dotnet New CajuLearn Clean Architecture with .NET Core 3.0 🔥
Stars: ✭ 228 (+185%)
Kafka Elasticsearch InjectorGolang app to read records from a set of kafka topics and write them to an elasticsearch cluster
Stars: ✭ 70 (-12.5%)
Digital RestaurantDDD. Event sourcing. CQRS. REST. Modular. Microservices. Kotlin. Spring. Axon platform. Apache Kafka. RabbitMQ
Stars: ✭ 222 (+177.5%)
OckamEnd-to-end encrypted messaging and mutual authentication between cloud and edge-device applications
Stars: ✭ 395 (+393.75%)
chuck-norris-streamsKafka, Debezium and Fuse demonstration based on Chuck Norris movies!
Stars: ✭ 25 (-68.75%)
GimelBig Data Processing Framework - Unified Data API or SQL on Any Storage
Stars: ✭ 216 (+170%)
Spiderman基于 scrapy-redis 的通用分布式爬虫框架
Stars: ✭ 392 (+390%)
BdsBlockchain data parsing and persisting results
Stars: ✭ 1,032 (+1190%)
JPStreamJPStream: JSONPath Stream Processing in Parallel
Stars: ✭ 19 (-76.25%)
Practical.cleanarchitectureAsp.Net Core 5 Clean Architecture (Microservices, Modular Monolith, Monolith) samples (+Blazor, Angular 11, React 17, Vue 2.6), Domain-Driven Design, CQRS, Event Sourcing, SOLID, Asp.Net Core Identity Custom Storage, Identity Server 4 Admin UI, Entity Framework Core, Selenium E2E Testing, SignalR Notification, Hangfire Tasks Scheduling, Health Checks, Security Headers, ...
Stars: ✭ 639 (+698.75%)
typebusFramework for building distributed microserviceies in scala with akka-streams and kafka
Stars: ✭ 14 (-82.5%)
Event Sourcing CastanhaAn Event Sourcing service template with DDD, TDD and SOLID. It has High Cohesion and Loose Coupling, it's a good start for your next Microservice application.
Stars: ✭ 68 (-15%)
Anotherkafkamonitor AkmAnother app which used to monitor the progress of Kafka Producer and Consumer
Stars: ✭ 36 (-55%)
Rust RdkafkaA fully asynchronous, futures-based Kafka client library for Rust based on librdkafka
Stars: ✭ 637 (+696.25%)