Streaming Analytics platform, built with Apache Flink and Kafka

Real-Time IoT data Simulator written in Scala lang to feed kafka Producer

Notifications Engine

This project can be used as a tutorial showing to to use twiiter4j of twitter to stream. Use Apache Kafka as a producer, and Apache Spark as a consumer

Apache Kafka Producer and Consumer which uses Spark-Streaming and Avro Serialization written in Scala.

Colaberry Scala immersion training

Kafka Streams DSL for Scala examples

This is a basic example to show CEP in flink with kafka

Robot Inventory Exercise using Scala, Play2, Kafka and Cassandra

☁️ Simple akka-kafka producer packaged for k8s and Confluent Cloud

A data pipeline built using Apache Kafka and Apache Spark, implemented in Scala.

BigData concept for Lambda Architecture design pattern, Apache Kafka -> for streaming/data pipeline integration, Apache Spark -> for distributed data processing, RESTful, services -> Akka HTTP

Place where i put all my frequently used spark/hadoop/kafka/big data stuff

Akka Streams - Kafka - Spark Streaming

Stream processing of the T-Drive trajectory data sample

Simple big data pipeline

An end-to-end batch data pipeline for e-commerce analytics, built with Scala, Spark, HDFS, Hive, Postgres, and Jenkins. The system is enhanced with a parallel streaming pipeline using Kafka for real-time Twitter trend analysis.

Alert when a new version of a repository is released