ExamplesDemo applications and code examples for Confluent Platform and Apache Kafka
Stars: ✭ 571 (-18.19%)
Fs2 KafkaKafka client for functional streams for scala (fs2)
Stars: ✭ 75 (-89.26%)
CamusMirror of Linkedin's Camus
Stars: ✭ 81 (-88.4%)
RedpandaRedpanda is the real-time engine for modern apps. Kafka API Compatible; 10x faster 🚀 See more at vectorized.io/redpanda
Stars: ✭ 3,114 (+346.13%)
Schema RegistryA CLI and Go client for Kafka Schema Registry
Stars: ✭ 105 (-84.96%)
MaterializeMaterialize lets you ask questions of your live data, which it answers and then maintains for you as your data continue to change. The moment you need a refreshed answer, you can get it in milliseconds. Materialize is designed to help you interactively explore your streaming data, perform data warehousing analytics against live relational data, or just increase the freshness and reduce the load of your dashboard and monitoring tasks.
Stars: ✭ 3,341 (+378.65%)
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 (+7.88%)
StreamlineStreamLine - Streaming Analytics
Stars: ✭ 151 (-78.37%)
Voik♒︎ [WIP] An experimental ~distributed~ commit-log
Stars: ✭ 200 (-71.35%)
GimelBig Data Processing Framework - Unified Data API or SQL on Any Storage
Stars: ✭ 216 (-69.05%)
Azure Event Hubs SparkEnabling Continuous Data Processing with Apache Spark and Azure Event Hubs
Stars: ✭ 140 (-79.94%)
Flink Learningflink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
Stars: ✭ 11,378 (+1530.09%)
Data AcceleratorData Accelerator for Apache Spark simplifies onboarding to Streaming of Big Data. It offers a rich, easy to use experience to help with creation, editing and management of Spark jobs on Azure HDInsights or Databricks while enabling the full power of the Spark engine.
Stars: ✭ 247 (-64.61%)
TributaryStreaming reactive and dataflow graphs in Python
Stars: ✭ 231 (-66.91%)
HydraA real-time data replication platform that "unbundles" the receiving, transforming, and transport of data streams.
Stars: ✭ 68 (-90.26%)
Schema RegistryConfluent Schema Registry for Kafka
Stars: ✭ 1,647 (+135.96%)
Kafka RestConfluent REST Proxy for Kafka
Stars: ✭ 1,863 (+166.91%)
Cp DemoConfluent Platform Demo including Apache Kafka, ksqlDB, Control Center, Replicator, Confluent Schema Registry, Security
Stars: ✭ 278 (-60.17%)
Cp AnsibleAnsible playbooks for the Confluent Platform
Stars: ✭ 285 (-59.17%)
Streamxkafka-connect-s3 : Ingest data from Kafka to Object Stores(s3)
Stars: ✭ 96 (-86.25%)
Cp Docker Images[DEPRECATED] Docker images for Confluent Platform.
Stars: ✭ 975 (+39.68%)
JockoKafka implemented in Golang with built-in coordination (No ZK dep, single binary install, Cloud Native)
Stars: ✭ 4,445 (+536.82%)
Open Bank MarkA bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.
Stars: ✭ 81 (-88.4%)
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 (-40.69%)
SpartaReal Time Analytics and Data Pipelines based on Spark Streaming
Stars: ✭ 513 (-26.5%)
Jeesuite Libs分布式架构开发套件。包括缓存(一二级缓存、自动缓存管理)、队列、分布式定时任务、文件服务(七牛、阿里云OSS、fastDFS)、日志、搜索、分布式锁、分布式事务、集成dubbo、spring boot支持以及常用的工具包等。
Stars: ✭ 584 (-16.33%)
Ad examplesA collection of anomaly detection methods (iid/point-based, graph and time series) including active learning for anomaly detection/discovery, bayesian rule-mining, description for diversity/explanation/interpretability. Analysis of incorporating label feedback with ensemble and tree-based detectors. Includes adversarial attacks with Graph Convolutional Network.
Stars: ✭ 641 (-8.17%)
JailerDatabase Subsetting and Relational Data Browsing Tool.
Stars: ✭ 576 (-17.48%)
NetdiscoveryNetDiscovery 是一款基于 Vert.x、RxJava 2 等框架实现的通用爬虫框架/中间件。
Stars: ✭ 573 (-17.91%)
HermesFast and reliable message broker built on top of Kafka.
Stars: ✭ 665 (-4.73%)
Rust RdkafkaA fully asynchronous, futures-based Kafka client library for Rust based on librdkafka
Stars: ✭ 637 (-8.74%)
Uwphook🔗 Add your Windows Store or UWP games to Steam
Stars: ✭ 566 (-18.91%)
Java Studyjava-study 是本人学习Java过程中记录的一些代码!从Java基础的数据类型、jdk1.8的Lambda、Stream和日期的使用、 IO流、数据集合、多线程使用、并发编程、23种设计模式示例代码、常用的工具类, 以及一些常用框架,netty、mina、springboot、kafka、storm、zookeeper、redis、elasticsearch、hbase、hive等等。
Stars: ✭ 571 (-18.19%)
Webtorrent CliWebTorrent, the streaming torrent client. For the command line.
Stars: ✭ 633 (-9.31%)
HysteriaplayerObjective-C audio player, sitting on top of AVPlayer
Stars: ✭ 568 (-18.62%)
Lol HtmlLow output latency streaming HTML parser/rewriter with CSS selector-based API
Stars: ✭ 566 (-18.91%)
Pmacctpmacct is a small set of multi-purpose passive network monitoring tools [NetFlow IPFIX sFlow libpcap BGP BMP RPKI IGP Streaming Telemetry].
Stars: ✭ 677 (-3.01%)
Membrane coreThe core of the Membrane Framework, advanced multimedia processing framework
Stars: ✭ 662 (-5.16%)
FaustPython Stream Processing
Stars: ✭ 5,899 (+745.13%)
Homehostself-hosted, Netflix-like app made for streaming
Stars: ✭ 564 (-19.2%)
FreestyleA cohesive & pragmatic framework of FP centric Scala libraries
Stars: ✭ 627 (-10.17%)
LibrdkafkaThe Apache Kafka C/C++ library
Stars: ✭ 5,617 (+704.73%)
CentrifugoScalable real-time messaging server in a language-agnostic way. Set up once and forever.
Stars: ✭ 5,649 (+709.31%)
Kafka Streams Machine Learning ExamplesThis project contains examples which demonstrate how to deploy analytic models to mission-critical, scalable production environments leveraging Apache Kafka and its Streams API. Models are built with Python, H2O, TensorFlow, Keras, DeepLearning4 and other technologies.
Stars: ✭ 661 (-5.3%)
DoctorkDoctorK is a service for Kafka cluster auto healing and workload balancing
Stars: ✭ 615 (-11.89%)
StreamlyBeautiful Streaming, Concurrent and Reactive Composition (Haskell)
Stars: ✭ 553 (-20.77%)
FfmpegMirror of https://git.ffmpeg.org/ffmpeg.git
Stars: ✭ 27,382 (+3822.92%)