From a176b18ac05e646a8719095714ed72fb600664f4 Mon Sep 17 00:00:00 2001 From: Mohammed Sohail Date: Thu, 12 Jan 2023 10:32:12 +0000 Subject: [PATCH] del: jetstream docs, replace with issue --- docs/jetsream.md | 56 ------------------------------------------------ 1 file changed, 56 deletions(-) delete mode 100644 docs/jetsream.md diff --git a/docs/jetsream.md b/docs/jetsream.md deleted file mode 100644 index ed91f9d..0000000 --- a/docs/jetsream.md +++ /dev/null @@ -1,56 +0,0 @@ -## NATS JetStream - -### Server setup - -- Enable `-js -sd` - -## Stream setup - -```go -_, err = js.AddStream(&nats.StreamConfig{ - Name: streamName, - // Remove from JS once Acked (Should not be used with 1 consumer which acts as a relayer e.g. Benthos). - // Retention: nats.WorkQueuePolicy, - // MaxAge allows us to replay it within 48 hrs - MaxAge: time.Hour * 48, - Storage: nats.FileStorage, - Subjects: []string{streamSubjects}, - // Sliding window dedup period. - Duplicates: time.Minute * 5, -}) -``` - -## Producer - -```go -// nats.MsgId is the unique identifier for dedup -ctx.Publish("*", []byte("*"), nats.MsgId("*")) -``` - -## Consumer setup - -- Explicit ACK -- Durable -- Deliver: all - -### Benthos example - -```toml -input: - label: jetstream - nats_jetstream: - urls: - - nats://127.0.0.1:4222 - subject: "*" - durable: benthos - deliver: all - output: - stdout: - codec: lines -``` - -### Replay example - -```bash -nats sub "*" --all --start-sequence=$N -``` \ No newline at end of file