All the exercises from the book "Learning Spark", solved with Dataframes and Datasets, no stone unturned.

Solr Connection-Search-Delete-Update

Grafana datasource plugin for MongoDB

A scalable inference server for models optimized with OpenVINO™

A consumer of a Kafka topic based on Flink

It is a Big data architecture for get new and old tweets from hashtag

Mobile Network Operator Case Study with Flink, Kafka, Cassandra, Spring on Docker Compose and Kubernetes with a little bit of React and GraphQL.

大数据入门指南 ⭐

The "REST With Spring" Course:

Docker container image of Apache Flink

Java module for reading from Kafka and processing data using Apache Flink

Spring Boot app which executes a remote Flink job.

A real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernetes deployed on the cloud

Docker files of the project that has configuration to up Kafka, Zookeeper, Flume, Spark, MongoDB and Spring Boot.

Experiment with Kafka, Debezium, and ksqlDB. research-service: Performs MySQL record manipulation. Source Connectors: Monitor MySQL changes, push messages to Kafka. Sink Connectors and kafka-resear…

Debezium Engine for Spring Boot (POC)

CDC Spring Boot with Embedded Debezium connector, the goal of the project is to pull records from postgres to h2 database automatically when ever there is change in source data

mysql -> debezium -> kafka -> flink -> elasticsearch with docker

This project has a example to how propagate data between Postgres and ElasticSearch using CDC Debezium

Debezium Example | Postgres ➡️ Elasticsearch

Change Data Capture with Debezium

CDC spring boot app with debezium

Spring Boot sample project demonstrating the usage of the Debezium framework for CDC on MySQL database

Grafana Couchbase datasource plugin