event-processing

Distributed Stream and Batch Processing

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

Technical solution to implement event processing prioritization with Apache Kafke using the concept of buckets.

Apache Flink CEP: Automatic pattern generation and processing

Coyote Data Exchange Toolkit - Mediate or Integrate Anything

A Generic Benchmarking Platform for Big Data Architectures

Front-end framework for processing user interface events in JavaFX

The Bootstrapping & Reliability Framework for Apache Flink. Fail fast on configuration, serialize natively without Kryo, and bootstrap stream pipelines with zero boilerplate.

Garbage-free (green) toolset to implement a Thread Actor with asynchronous API

Spring Boot backend system for ingesting machine events with deduplication, concurrent-safe updates, and statistical analytics over time windows.

Spring Boot-based quiz leaderboard system that processes distributed quiz events, eliminates duplicate submissions, aggregates participant scores, and generates accurate leaderboards using idempotent event processing.

Distributed Event Processing engine using Java, Spring boot, Apache kafka, Apache cassandra, Prometheus, Grafana, and Docker.

Java 21 event-processing platform with Kafka pipelines, transactional outbox/inbox, idempotency, DLQ replay, and pluggable delivery sinks.

Two Spring Boot microservices for streaming order processing and real-time net position tracking with validation, idempotency, throttling, concurrency safety, and REST APIs.

🚀 Event-driven system with transactional outbox pattern | Java 23 | PostgreSQL 18 | n8n | HikariCP connection pooling | SLF4J for error handling | Automatic event processing | 100% reliability | Production-ready architecture

The TIBCO Streaming Maven Plugin Provides the ability to build, launch, and manage Streaming applications through the open source tool Maven.