#

stream-processing

Here are 302 public repositories matching this topic...

questdb

questdb / questdb

QuestDB is a high performance, open-source, time-series database

Updated Sep 17, 2026
Java

flink-learning

zhisheng17 / flink-learning

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

mysql redis elasticsearch streaming kafka spark influxdb rabbitmq clickhouse hbase stream-processing opentsdb loki flink rocketmq

Updated May 6, 2026
Java

hazelcast / hazelcast

Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.

java caching distributed-systems real-time big-data hazelcast scalability distributed-computing distributed stream-processing in-memory low-latency hacktoberfest data-insights data-in-motion

Updated Sep 17, 2026
Java

apache / hudi

Upserts, Deletes And Incremental Processing on Big Data.

bigdata stream-processing data-integration datalake apachespark hudi apachehudi incremental-processing apacheflink

Updated Sep 17, 2026
Java

siddhi-io / siddhi

Stream Processing and Complex Event Processing Engine

library cloud cep cncf stream-processing cloud-native complex-event-processing online-learning streaming-data-processing

Updated May 5, 2026
Java

spring-attic / spring-cloud-dataflow

A microservices-based Streaming and Batch data processing in Cloud Foundry and Kubernetes

orchestration stream-processing cloud-native microservices-architecture predictive-analytics batch-processing datapipelines

Updated Apr 30, 2025
Java

hazelcast-jet

hazelcast / hazelcast-jet

Distributed Stream and Batch Processing

java kafka big-data stream-processing low-latency batch-processing cdc hacktoberfest event-processing

Updated Dec 19, 2024
Java

spring-cloud / spring-cloud-stream

Framework for building Event-Driven Microservices

microservices reactive messaging stream-processing event-driven-microservices cloud-native

Updated Sep 17, 2026
Java

apache / streampipes

Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.

iot microservices dashboard analytics edge stream-processing iot-platform s7 iiot self-service iot-analytics opcua

Updated Sep 17, 2026
Java

smooks / smooks

An extensible Java framework for building event-driven applications that break up XML and non-XML data into chunks for data integration

java etl analytics xml pipelines sax stream-processing event-driven chunking smooks enterprise-integration

Updated Nov 24, 2025
Java

confluentinc / ksql

The database purpose-built for stream processing applications.

real-time sql kafka interactive stream-processing kafka-connect materialized-views ksqldb ksqldb-documentation ksqldb-tutorials streaming-queries event-streaming-database

Updated Sep 17, 2026
Java

streamnative / pulsar-flink

Elastic data processing with Apache Pulsar and Apache Flink

schema sql catalog schema-registry stream-processing pulsar apache-flink flink data-processing batch-processing flink-stream-processing apache-pulsar flink-connector

Updated Nov 10, 2022
Java

raystack / dagger

Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.

framework influxdb prometheus stream-processing dataops apache-flink apache-kafka real-time-analytics real-time-processing

Updated Aug 29, 2023
Java

bbejeck / kafka-streams-in-action

Source code for the Kafka Streams in Action Book

streaming kafka stream-processing streaming-data kafkastreams

Updated Jul 11, 2021
Java

zakariamaaraki / RemoteCodeCompiler

An online code compiler supporting 11 programming languages (Java, Kotlin, Scala, C, C++, C#, Golang, Python, Ruby, Rust and Haskell) for competitive programming and coding interviews.

java docker kafka spring-boot serverless rabbitmq grpc competitive-programming stream-processing kafka-streams coding-interviews

Updated Jun 2, 2024
Java

LearningJournal / Kafka-Streams-Real-time-Stream-Processing

This is the central repository for all materials related to Kafka Streams : Real-time Stream Processing! Book by Prashant Pandey.

kafka streams stream-processing kafka-consumer java-8 apache-kafka kafka-producer kafka-client kafka-streams avro-schema messaging-system avro-kafka kafka-examples real-time-stream-processing json-kafka

Updated Jul 29, 2020
Java

stream-registry

ExpediaGroup / stream-registry

Stream Discovery and Stream Orchestration

streams stream-processing metadata-management oss-portal-featured

Updated Jan 7, 2026
Java

Hurence / logisland

Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.

elasticsearch kafka big-data spark cassandra influxdb analytics solr stream-processing pattern-recognition complex-event-processing kafka-streams

Updated Oct 16, 2023
Java

trK54Ylmz / kafka-spark-streaming-example

Simple examle for Spark Streaming over Kafka topic

java kafka spark stream-processing

Updated Oct 13, 2020
Java

tall15421542-lab / ticket-master

A high-throughput, consistent ticket reservation system that can process 83000+ reservations per second

java kubernetes golang distributed-systems kafka terraform load-testing gcp stream-processing kafka-streams k6 system-design

Updated Aug 7, 2025
Java

Add this topic to your repo

To associate your repository with the stream-processing topic, visit your repo's landing page and select "manage topics."