Spring Boot 2 service that forms the analysis tier of the TweetPipe streaming data pipeline. This application consumes tweets from a Kafka topic, analyses them, and will persist the result to a target database.

Poc project for data streaming using spring-webflux.

the real-time computing engine for open-telemetry

A java SDK to allow users to get the best of streamdata.io in a few lines of code.

Kafka Resources

Storm topology to stream in tweets, perform basic sentiment analytics and store results in Hive table (using HiveBolt).

Adaptive Decision Forest(ADF) is an incremental machine learning framework called to produce a decision forest to classify new records. ADF is capable to classify new records even if they are associated with previously unseen classes. ADF also is capable of identifying and handling concept drift; it, however, does not forget previously gained kn…

Fl!nk easy examples

This repository contains an alternative Apache Spark-based analysis tier for the TweetPipe streaming data pipeline

An Android mobile application that uses a customized libjingle library for real-time music streaming

kafka-java-scala-mariadb

jKool Event Streaming Library -- telemetry collection, simulation and streaming to jKool enabled servers, jKool Cloud.

🤺 coding challenge from Insight Data Engineering Program 💯

A "real time" dataset generator using device sensors and cameras

Spring Boot 2 service that forms the collection tier of the TweetPipe streaming data pipeline. This application consumes tweets matching specific keywords from Twitter and publishes them to a Kafka topic.

Android library for listening to Image Reader surface (Library developed to be used as binding in Xamarin)