793 Open source projects that are alternatives of or similar to Spark Streaming With Kafka

Sample Event Sourcing implementation with .NET Core

KafkaFlow is a .NET framework to consume and produce Kafka messages with multi-threading support. It's very simple to use and very extendable. You just need to install, configure, start/stop the bus with your app and create a middleware/handler to process the messages.

前端性能监控系统,消息队列,高可用,集群等相关架构

An Hexagonal Architecture with DDD + Aggregates + Event Sourcing using .NET Core, Kafka e MongoDB (Blog Engine)

销售系统项目，spring+spring mvc+mybatis+dubbo+kafka+redis+maven

📊 Cube — Open-Source Analytics API for Building Data Apps

Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.

A Docker container with a full Hadoop cluster setup with Spark and Zeppelin

The AsyncAPI specification allows you to create machine-readable definitions of your asynchronous APIs.

Kafka backed service library.

all kinds of scrapy demo

Webex Bot SDK for Node.js (deprecated in favor of https://github.com/webex/webex-bot-node-framework)

This is a based on playframwork for submit spark app

❤for real-time DataOps - where the application and data fabric blends - Lenses

Kafka Tutorials microsite

Kafka consumer lag monitor

Spring-Shiro-Spark是Spring-Boot Hibernate Spark Spark-SQL Shiro iView VueJs... ...的集成尝试

The Internals of Apache Spark

Content for architecting a data science platform for products using Luigi, Spark & Flask.

Java SDK for CloudEvents

MongoDB Kafka Connector

Examples for Deep Learning/Feature Store/Spark/Flink/Hive/Kafka jobs and Jupyter notebooks on Hops

An Airflow docker image preconfigured to work well with Spark and Hadoop/EMR

以Kafka为存储介质，提供异步Http RPC的中间件

This application comes as Spark2.1-as-Service-Provider using an embedded, Reactive-Streams-based, fully asynchronous HTTP server

Apache Kafka on Docker

Demo applications and code examples for Confluent Platform and Apache Kafka

Data science and Big Data with Python

SparkTDA is a package for Apache Spark providing Topological Data Analysis Functionalities.

Suite of tools for deploying and training deep learning models using the JVM. Highlights include model import for keras, tensorflow, and onnx/pytorch, a modular and tiny c++ library for running math code and a java based math library on top of the core c++ library. Also includes samediff: a pytorch/tensorflow like library for running deep learni…

支持mysql、MongoDB数据变更订阅分发

Spark examples

A Spark SQL extension which provides SQL Standard Authorization for Apache Spark

Official code repository for GATK versions 4 and up

Distributed Deep learning with Keras & Spark

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

本人的RabbitMQ和Kafka详细笔记以及示例代码

450+ AWS, Hadoop, Cloud, Kafka, Docker, Elasticsearch, RabbitMQ, Redis, HBase, Solr, Cassandra, ZooKeeper, HDFS, Yarn, Hive, Presto, Drill, Impala, Consul, Spark, Jenkins, Travis CI, Git, MySQL, Linux, DNS, Whois, SSL Certs, Yum Security Updates, Kubernetes, Cloudera etc...

Applying Lambda Architecture with Spark, Kafka, and Cassandra.

Instagram Clone - Cloning Instagram for learning purpose

Kafka exporter for Prometheus

light, fast, scalable, streaming microservices made easy

Bireme is an incremental synchronization tool for the Greenplum / HashData data warehouse

GraphQL Rust Demo

关于kafka的一些相关使用示例代码。

Tool to ease and automate Apache Kafka cluster configuration management

Spark SQL index for Parquet tables

Vagrant projects for various use-cases with Spark, Zeppelin, IPython / Jupyter, SparkR

Confluent's Apache Kafka .NET client

Feature Store for Machine Learning

.NET event stream projection and scheduling platform with EventStore, CosmosDb, Equinox and Kafka integrations

Distributed t-SNE via Apache Spark

🌿 基于springboot的快速学习示例,整合自己遇到的开源框架,如：rabbitmq(延迟队列)、Kafka、jpa、redies、oauth2、swagger、jsp、docker、spring-batch、异常处理、日志输出、多模块开发、多环境打包、缓存cache、爬虫、jwt、GraphQL、dubbo、zookeeper和Async等等📌

Karapace - Your Kafka essentials in one tool

A bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.

A robust, and flexible open source User & Entity Behavior Analytics (UEBA) framework used for Security Analytics. Developed with luv by Data Scientists & Security Analysts from the Cyber Security Industry. [PRE-ALPHA]

Cookbook to install Hadoop 2.0+ using Chef

Spark job for dependency links