/idempotencer

initially adapter for kafka which guarantee idempotence without losing asynchronous

Primary LanguageGo

Idempotencer

With project aims to implement inboxer/outboxer patterns over Kafka as upstream, Postgres as persistent storage and ZeroMQ as downstream.

There may be alternatives in the future to change persistent storage.

Rules

- Prefer internal `errors.Error` over standart `error`-interface

TODO

https://pkg.go.dev/github.com/pebbe/zmq4?tab=doc#pkg-overview

See how to configure hight water mark (or it not needed in my schema)