tcosnr
Follow
Lists (1)
Stars
The Open-Source toolkit to build your own reliable and secure Industrial IoT platform.
SolarX is a project aiming to practice a number of different tools, from the databases and etl related work, data streaming using kafka, data processing with kafka and python, web-sockets in the no…
🐳✨ Fully automated Apache Kafka® and Confluent Docker based examples // 👷♂️ Easily build examples or reproduction models
Apache Kafka® running on Kubernetes
Confluent Platform Demo including Apache Kafka, ksqlDB, Control Center, Schema Registry, Security, Schema Linking, and Cluster Linking
Apache Kafka, Apache Flink and Confluent Platform examples and demos
Open-Source Web UI for Apache Kafka Management
Framework for manufacturing data management
A streaming data pipeline uses Kafka as the backbone and Flink for data processing and transformations. Kafka Connect is used for writing the streams to S3 compatible blob stores and Redis (low lat…
Platform to consume and analyze stock market data in real time
Implemented an ETL pipeline for factory sensor data using Kafka to process and stream data to Hadoop for storage, Druid for real-time analytics, and Redis for fast data access.
Developed a scalable backend system using SQL, PostgreSQL partitioning, indexing, and Redis caching to manage billions of records and optimize query performance. Leveraged sharding and Apache Kafka…
An end-to-end real-time data streaming pipeline that leverages Kafka and Spark Streaming to analyse social media sentiment trends.
The Market Sentiment Analysis project is a real-time system that ingests soc-med discussion data (finance, politics, economics) for market trend analysis. Using Java, Spring Boot, Kafka, and Redis,…
Prometheus, Grafana, Kafka, Zipkin, Redis, Elasticsearch and Logstash Integrations with Spring Boot 3, Java 21 and Docker. Integration Tests with Testcontainers for Controller. Unit Tests for Contr…
A demo project demonstrating how to read and write data into a Redis-backed state store using Kafka Streams.
This Scrapy project uses Redis and Kafka to create a distributed on demand scraping cluster.
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
Real-time Data Integration and Transformation: use SQL to transform, deliver, and act on fast-changing data.
Flink CDC is a streaming data integration tool
Python Stream Processing. A Faust fork
Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
Open-source IoT Platform - Device management, data collection, processing and visualization.