💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算)；🚀 支持运行过程中增删topic；🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。

基于Spark的行为日志分析系统

Apache Kafka, Apache Spark data engineering pipeline

Spark Structured Streaming

A repository to practice with Kafka exercises, Spark Structured Streaming exercises and Kafka & Spark Structured Streaming (combined) exercises

Dataflow task simulation with combination of CDC formation and streaming data read/writes

A Real-Time Amazon Stock Price Visualization Project using Kafka Messaging System, Spark Structured Streaming, Flask and Chart.js

Business rules engine for Apache spark streaming