A high-performance SQL engine written in C++, designed for real-time data processing. It can read millions of rows per second from ClickHouse, Kafka, Pulsar, or REST, and write results back with low latency. With native support for JOIN, UPSERT, CDC, and LOOKUP, Timeplus Proton is ideal for real-time streaming processing and scalable ETL.

基于node(nest.js + mysql)的用户组织权限管理系统,集成kafka消息推送（基于simple-push-center微服务）

👋 Management the blank service for the blanksystem as template.

Kafka Streams based stateful stream processing application on Oracle Application Container Cloud

introduction to the concept related to the use of Kafka

Captures local Postgres changes via Debezium, publishes them to Kafka, and uses a C# consumer for upserts/deletes in cloud Postgres. Deployed with Docker Compose, with optional Prometheus and Grafana for monitoring.

Kafka Demo in Express.js (TypeScript) and Event Driven approach.

nodes typescript mongo db connectivity example with Kafka integration

Demo project for Spring Boot as Kafka Producer

Realtime metrics calculation pipeline using kafka, elasticsearch and kibana.

Kafka Avro, Schema Registry, Confluent Rest Proxy Examples and Endpoints Using Landoop Kafka UI

Kafka streams processing using simple Java Classes

Assignatura Bases de Dades Avançades d'Enginyeria Informàtica (Universitatd de Barcelona)

WordCount with Kafka Streams

The system includes django container and integrates it with an open-source logging solution, including Fluentbit, Deeplog, and PostgreSQL.

A kafka standalone server for integration testing

Spark Streaming using Apache Kafka. Event Based Streaming.