exactly-once-processing

Here are 9 public repositories matching this topic...

Elijas / redis-message-queue

Lightweight Python message queuing with Redis and built-in publish-side deduplication.

python redis queue pubsub message-acknowledgement message-queue pub-sub task-queue data-processing deduplication redis-queue worker-pool message-broker exactly-once idempotent horizontal-scaling exactly-once-processing task-queues

Updated Jul 7, 2026
Python

ambarltd / ambar_demo

Star

An at your own pace demonstration of the technology that powers Ambar! Checkout the ReadMe for details on how to get started.

kafka kafka-consumer kafka-producer scaleable ordering debezium low-code data-streaming exactly-once-processing

Updated Apr 3, 2024
JavaScript

suriyakrishna / scala-kafka-application

Star

Repository with sample code to build Kafka Streaming Application in Scala.

mysql scala kafka mysql-database kafka-consumer kafka-producer kafka-mysql exactly-once-processing kafka-rebalance-listener kakfa-exactly-once-processing kafka-commit kafka-commit-sync kafka-commit-async kafka-exception-handling kafka-offset-management kafka-offset-external-datastore kafka-scala scala-kafka

Updated Nov 14, 2023
Scala

BITS08SATHYA / ares-scheduler

Star

Ares: Multi-Cluster Kubernetes Scheduler with GPU Topology Optimization (Intra-Node, Inter-Node, Inter-Cluster) and Exactly-Once Execution Semantics

kubernetes distributed-systems scheduler drf prometheus grafana-dashboard cicd nvidia-smi pcie priority-scheduling nvlink split-brain idempotent-requests gpu-scheduler exactly-once-processing pcie5 multi-cluster-scheduling distributed-leasing

Updated Jun 10, 2026
Go

albeRoss / kafkapipeline

Star

A data processing pipeline in Kafka that guarantees E2E exactly once semantics. Administrative scripts to deploy Kafka cluster on AWS.

kafka aws-cli kafka-consumer java-8 kafka-producer producer-consumer mapdb exactly-once-processing exactly-once-semantic

Updated Oct 14, 2020
Java

emitskevich / kafka-reo

Star

Kafka Replicator Exactly-Once - the tool to replicate data with exactly-once guarantee between different clusters of Apache Kafka.

kafka kafka-streams mirror-maker exactly-once-processing

Updated Aug 30, 2024
Java

chahario / Url-Shortner

Star

Production-shaped URL shortener with per-visit billing

redis kafka spring-boot postgresql rate-limiting cache-aside exactly-once-processing java21

Updated Jun 27, 2026
Java

Shineuptillast / Kafka

Star

practice files of kafka

schema-registry topic consumer partition producer consumer-group exactly-once-processing avro-serializer json-serialzer

Updated Jul 9, 2023
Python

bsure-analytics / flechtwerk

Star

Truly async Python stream processing with real Kafka transactions for exactly-once delivery, and an MQTT→Kafka bridge that ACKs only after Kafka has the data.

python mqtt kafka async stream-processing exactly-once-processing

Updated Aug 26, 2026
Python

Add this topic to your repo

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

Learn more