LogislandScalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.
Stars: ✭ 97 (-35.76%)
KsppA high performance/ real-time C++ Kafka streams framework (C++17)
Stars: ✭ 80 (-47.02%)
Repository个人学习知识库涉及到数据仓库建模、实时计算、大数据、Java、算法等。
Stars: ✭ 92 (-39.07%)
Kattlo CliKattlo CLI Project
Stars: ✭ 58 (-61.59%)
Sparkstreaming💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算);🚀 支持运行过程中增删topic;🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。
Stars: ✭ 179 (+18.54%)
Bigdata PlaygroundA complete example of a big data application using : Kubernetes (kops/aws), Apache Spark SQL/Streaming/MLib, Apache Flink, Scala, Python, Apache Kafka, Apache Hbase, Apache Parquet, Apache Avro, Apache Storm, Twitter Api, MongoDB, NodeJS, Angular, GraphQL
Stars: ✭ 177 (+17.22%)
Voik♒︎ [WIP] An experimental ~distributed~ commit-log
Stars: ✭ 200 (+32.45%)
TweetmapA real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernetes deployed on the cloud
Stars: ✭ 28 (-81.46%)
Streamxkafka-connect-s3 : Ingest data from Kafka to Object Stores(s3)
Stars: ✭ 96 (-36.42%)
StormkafkamonDumps state of Storm Kafka consumers
Stars: ✭ 99 (-34.44%)
Fiflowflink-sql 在 flink 上运行 sql 和 构建数据流的平台 基于 apache flink 1.10.0
Stars: ✭ 100 (-33.77%)
wink-statisticsFast & numerically stable statistical analysis
Stars: ✭ 36 (-76.16%)
trafficMassively real-time traffic streaming application
Stars: ✭ 25 (-83.44%)
litemall-dw基于开源Litemall电商项目的大数据项目,包含前端埋点(openresty+lua)、后端埋点;数据仓库(五层)、实时计算和用户画像。大数据平台采用CDH6.3.2(已使用vagrant+ansible脚本化),同时也包含了Azkaban的workflow。
Stars: ✭ 36 (-76.16%)
Kafka UiOpen-Source Web GUI for Apache Kafka Management
Stars: ✭ 230 (+52.32%)
WirbelsturmWirbelsturm is a Vagrant and Puppet based tool to perform 1-click local and remote deployments, with a focus on big data tech like Kafka.
Stars: ✭ 332 (+119.87%)
Scalatest Embedded KafkaA library that provides an in-memory Kafka instance to run your tests against.
Stars: ✭ 292 (+93.38%)
Kafkastreams CepComplex Event Processing on top of Kafka Streams
Stars: ✭ 257 (+70.2%)
God Of Bigdata专注大数据学习面试,大数据成神之路开启。Flink/Spark/Hadoop/Hbase/Hive...
Stars: ✭ 6,008 (+3878.81%)
KsqlThe database purpose-built for stream processing applications.
Stars: ✭ 4,668 (+2991.39%)
KukulcanA REPL for Apache Kafka
Stars: ✭ 103 (-31.79%)
Seldon ServerMachine Learning Platform and Recommendation Engine built on Kubernetes
Stars: ✭ 1,435 (+850.33%)
Kafka WorkshopMaterials (slides and code) for Kafka and Kafka Streams Workshop
Stars: ✭ 44 (-70.86%)
FaustPython Stream Processing
Stars: ✭ 5,899 (+3806.62%)
Roc ToolkitReal-time audio streaming over the network.
Stars: ✭ 673 (+345.7%)
Go StreamsA lightweight stream processing library for Go
Stars: ✭ 615 (+307.28%)
Demo Scene👾Scripts and samples to support Confluent Demos and Talks. ⚠️Might be rough around the edges ;-) 👉For automated tutorials and QA'd code, see https://github.com/confluentinc/examples/
Stars: ✭ 806 (+433.77%)
Stream ReactorStreaming reference architecture for ETL with Kafka and Kafka-Connect. You can find more on http://lenses.io on how we provide a unified solution to manage your connectors, most advanced SQL engine for Kafka and Kafka Streams, cluster monitoring and alerting, and more.
Stars: ✭ 753 (+398.68%)
Bandar LogMonitoring tool to measure flow throughput of data sources and processing components that are part of Data Ingestion and ETL pipelines.
Stars: ✭ 19 (-87.42%)
Kafka Streamsequivalent to kafka-streams 🐙 for nodejs ✨🐢🚀✨
Stars: ✭ 613 (+305.96%)
Cp Docker Images[DEPRECATED] Docker images for Confluent Platform.
Stars: ✭ 975 (+545.7%)
OblectoOblecto is a media server, which streams media you already own, and is designed to be at the heart of your entertainment experience. It runs on your home server to index and analyze your media such as Movies and TV Shows and presents them in an interface tailored for your media consupmtion needs.
Stars: ✭ 67 (-55.63%)
Java Kafka ClientOpenTracing Instrumentation for Apache Kafka Client
Stars: ✭ 101 (-33.11%)
WaterdropProduction Ready Data Integration Product, documentation:
Stars: ✭ 1,856 (+1129.14%)
Awesome KafkaA collection of kafka-resources
Stars: ✭ 116 (-23.18%)
GokaGoka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.
Stars: ✭ 1,862 (+1133.11%)
Real Time Ml ProjectA curated list of applied machine learning and data science notebooks and libraries across different industries.
Stars: ✭ 143 (-5.3%)
Node RdkafkaNode.js bindings for librdkafka
Stars: ✭ 1,799 (+1091.39%)
Streamingr/freemediaheckyeah
Stars: ✭ 147 (-2.65%)
Tensorflowtts😝 TensorFlowTTS: Real-Time State-of-the-art Speech Synthesis for Tensorflow 2 (supported including English, French, Korean, Chinese, German and Easy to adapt for other languages)
Stars: ✭ 2,382 (+1477.48%)
Echo🦄 开源社区系统:基于 SpringBoot + MyBatis + MySQL + Redis + Kafka + Elasticsearch + Spring Security + ... 并提供详细的开发文档和配套教程。包含帖子、评论、私信、系统通知、点赞、关注、搜索、用户设置、数据统计等模块。
Stars: ✭ 129 (-14.57%)
UltrasonicFree and open-source music streaming Android client for Subsonic API compatible servers
Stars: ✭ 149 (-1.32%)
SupersafebankSample Event Sourcing implementation with .NET Core
Stars: ✭ 142 (-5.96%)
Coinpusher📈 real-time cryptocurrency chart prediction based on neuronal-networks
Stars: ✭ 141 (-6.62%)
SmoothstreamWebcam, PiCamera streaming over the network with Python made easy.
Stars: ✭ 133 (-11.92%)
SamsaraSamsara is a real-time analytics platform
Stars: ✭ 132 (-12.58%)
My MomentsInstagram Clone - Cloning Instagram for learning purpose
Stars: ✭ 140 (-7.28%)