Make stream processing easier! Easy-to-use streaming application development framework and operation platform.

A Kafka Connect source connector that generates data for tests

JChunk is a lightweight and flexible library designed to provide multiple strategies for text chunking within Java applications

A library enabling DAG structuring of data processing programs such as ETLs

Reference Java & Spring implementation of the Open Ingestion Standard (OIS). It provides a secure, decoupled, and vendor-neutral enterprise data integration platform leveraging modern Java 25 features, Spring Boot, Spring AI and vector search infrastructure to orchestrate data flows

this repo for learning search engine such as elk and web search engine concept such as google to grow knowledge of software engineering

Parallel Streaming Transformation Loader

《DNA元基催化与肽计算》 在进化计算中, 软件函数文件进行 DNA 语义元基索引编码的 PDE 新陈代谢优化方式, 是一种有效的进化方式.

Metal is a data flow modeling platform. Metal supports visual modeling and submitting batch job.

A library enabling DAG structuring of data processing programs such as ETLs

Comms processing (ETL) with Apache Flink.

The AI agent for the German Jordanian University, focused on accurate university documents retrieval

Dataflow pipeline, Used for ETL

Pipeline microframework for data processing

A generic, multimodule framework for building scalable ETL (Extract, Transform, Load) processes using Apache Spark and Java. This framework is designed to be cloud-agnostic, maintainable, testable, and near-production-ready.

ETL Console is the Canary Islands Government's corporate solution for registering and executing ETL files developed using Pentaho Data Integration technology

Modern ETL Architecture Built with Flink 1.20.0 and Java 11

Streaming census data with Kafka

End-to-end data & ML platform for P2P lending analytics.[1] Features medallion architecture, Spark ETL, Airflow orchestration, MLOps with MLflow, and BI dashboards with Superset.

Advance Rag Project Using SPringboot and Spring AI , LLM Model