#

exactly-once

Here are 22 public repositories matching this topic...

build-on-aws / real-time-gaming-leaderboard-apache-flink

Example gaming leaderboard application covering streaming ingestion, CDC enrichment, processing and visualisation including demo of advance real-time analytics concepts like late data arrival, exactly-once, dynamic config, archival and on-demand replay

apache-flink replay change-data-capture real-time-analytics exactly-once dynamic-config amazon-managed-flink

Updated Nov 18, 2025
TypeScript

laravel-inbox-process

shipsaas / laravel-inbox-process

The Inbox Pattern/Process for Laravel apps. Ensure the ordering, uniqueness, and reliable handling of webhook requests.

inbox library laravel microservice design-patterns sequential ordering exactly-once inbox-pattern

Updated May 12, 2024
PHP

auraguardhq / aura-guard

Exactly-once + circuit breaker for agent tool calls (loops, retries, duplicate side effects)

python reliability circuit-breaker agents exactly-once idempotency tool-use llm agent-runtime tool-execution

Updated Mar 13, 2026
Python

kritibehl / faultline

Crash-safe distributed job execution with fencing tokens, lease recovery and deterministic failure validation.

python distributed-systems fault-tolerance postgresql job-queue exactly-once fencing-tokens

Updated Apr 17, 2026
Python

Elijas / redis-message-queue

Reliable Python message queuing with Redis and built-in deduplication. Publish once, process once, recover from crashes - across any number of producers and consumers.

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 Apr 15, 2026
Python

riffl

riffl / riffl

Riffl - generic streaming data ingestion framework

streaming kafka big-data bigdata s3 stream-processing data-lake parquet orc sink ingest streaming-data exactly-once data-mesh riffl

Updated Jan 28, 2023
Java

personali / kafka-clients-enhanced

Wrappers for Apache Kafka java clients

java client wrapper kafka maven persistent retry kafka-producer exactly-once

Updated Sep 5, 2023
Java

rahul1947 / SP06-Applications-of-Hashing

3 Problems from SP04 to be solved using HashMap/ HashSet instead of TreeMap/ TreeSet.

hashmap hashset exactly-once two-sum longest-increasing-subsequence

Updated Jan 18, 2019
Java

violetpay-org / queue-streamer

[Not Maintained] Processes and transfers message between Kafka topics with exactly-once delivery guarantees.

kafka message-queue kafka-consumer kafka-producer exactly-once

Updated Aug 8, 2024
Go

44437 / spring-kafka

compression avro schema-registry windowing kafka-streams exactly-once retention-policy reassignment idempotence consumer-groups ksqldb cleanup-policy streams-dsl transactional-consuming-producing

Updated Oct 14, 2024
Java

sjsj0 / rainstorm

RainStorm is a distributed stream processing system built on top of a hybrid distributed file system (HyDFS). Inspired by Apache Spark, Apache Flink, and HDFS/Cassandra design principles, RainStorm provides fault-tolerant, scalable stream processing with exactly-once semantics. The implementation is in Go and is intended to run across multiple VMs.

distributed-systems spark cassandra scalable stream-processing spark-streaming hdfs fault-tolerant exactly-once hydfs

Updated Mar 2, 2026
Go

saraengineer / exactly-once-delivery-kafka-nifi

Demo to implement real-time analysis project with exactly-once delivery enabled

kafka nifi exactly-once publishkafkarecord scriptedtransformrecord

Updated Nov 22, 2023
Shell

zeinab-dashti / spring-kafka-transactions-idempotent-write-demo

Exactly-Once Processing Across Kafka and Databases: Using Kafka Transactions + Idempotent Writes

kafka spring-boot avro schema-registry docker-compose postgresql transactions exactly-once idempotency

Updated Jun 25, 2025
Java

iontang / RealtimeSystem-Demo

kafka spark-streaming exactly-once

Updated Apr 19, 2018
Java

zeinab-dashti / spring-kafka-outbox-pattern-demo

Exactly-Once Processing Across Kafka and Databases: Using the Outbox Pattern

kafka spring-boot avro schema-registry docker-compose postgresql kafka-connect exactly-once idempotency outbox-pattern

Updated Jun 25, 2025
Java

Ledger-Once

2millerhenry / Ledger-Once

Exactly-once execution for AI agent tool calls. Prevent duplicate side effects caused by retries.

python sqlite openai retry ai-agents exactly-once idempotency agent-framework idempotency-key openai-api llm langchain langchain-python langchain-tools duplicate-prevention ai-agent-tools claude-code tool-calls openai-agents

Updated Mar 11, 2026
Python

Effiware / kafka-streamka

Kafka Streams API implementation for Python - built upon synchronous producer and consumer

python distributed-systems kafka event-driven kafka-streams exactly-once

Updated Feb 9, 2025
Python

aimov6464 / distributed-event-processor

Distributed event processing with Apache Spark Structured Streaming: Kafka ingestion, stateful deduplication, watermark-based window aggregation, and reproducible Parquet/Kafka outputs.

java distributed-systems kafka apache-spark stream-processing deduplication watermark exactly-once event-driven-architecture spark-structured-streaming stateful-streaming

Updated Jan 18, 2026
Java

filosganga / mnemosyne.rs

A Rust library for deduplicating process execution across distributed systems using DynamoDB.

database asynchronous dynamodb bloom-filter distributed deduplication duplicate-detection exactly-once idempotency

Updated Feb 3, 2026
Rust

abhisekgunnia / Spark-Streaming-Kafka

Example Template for Spark Streaming Applications

spark-streaming kafka-consumer exactly-once spark-streaming-kafka zookeeper-kafka spark-streaming-framework

Updated Jul 2, 2018
Scala

Improve this page

Add a description, image, and links to the exactly-once topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

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