NATS 文档中文站
首页
概述
NATS 概念
使用 NATS
运行 NATS 服务
参考文档
NGS
NEX
示例
首页
概述
NATS 概念
使用 NATS
运行 NATS 服务
参考文档
NGS
NEX
示例
简体中文

Source 和 Mirror 配置示例

带有 Source 和 Mirror 配置的流最好通过客户端 API 进行管理。如果您打算使用 NATS CLI 从命令行创建此类配置，应该使用 JSON。

nats stream add --config stream_with_sources.json

带有两个 Source 的示例流配置

最小化示例

{ "name": "SOURCE_TARGET", "subjects": [ "foo1.ext.*", "foo2.ext.*" ], "discard": "old", "duplicate_window": 120000000000, "sources": [ { "name": "SOURCE1_ORIGIN", }, ], "deny_delete": false, "sealed": false, "max_msg_size": -1, "allow_rollup_hdrs": false, "max_bytes": -1, "storage": "file", "allow_direct": false, "max_age": 0, "max_consumers": -1, "max_msgs_per_subject": -1, "num_replicas": 1, "name": "SOURCE_TARGET", "deny_purge": false, "compression": "none", "max_msgs": -1, "retention": "limits", "mirror_direct": false }

带附加选项

{ "name": "SOURCE_TARGET", "subjects": [ "foo1.ext.*", "foo2.ext.*" ], "discard": "old", "duplicate_window": 120000000000, "sources": [ { "name": "SOURCE1_ORIGIN", "filter_subject": "foo1.bar", "opt_start_seq": 42, "external": { "deliver": "", "api": "$JS.domainA.API" } }, { "name": "SOURCE2_ORIGIN", "filter_subject": "foo2.bar" } ], "consumer_limits": { }, "deny_delete": false, "sealed": false, "max_msg_size": -1, "allow_rollup_hdrs": false, "max_bytes": -1, "storage": "file", "allow_direct": false, "max_age": 0, "max_consumers": -1, "max_msgs_per_subject": -1, "num_replicas": 1, "name": "SOURCE_TARGET", "deny_purge": false, "compression": "none", "max_msgs": -1, "retention": "limits", "mirror_direct": false }

带有 镜像 的示例流配置

最小化示例

{ "name": "MIRROR_TARGET" "discard": "old", "mirror": { "name": "MIRROR_ORIGIN" }, "deny_delete": false, "sealed": false, "max_msg_size": -1, "allow_rollup_hdrs": false, "max_bytes": -1, "storage": "file", "allow_direct": false, "max_age": 0, "max_consumers": -1, "max_msgs_per_subject": -1, "num_replicas": 1, "name": "MIRROR_TARGET", "deny_purge": false, "compression": "none", "max_msgs": -1, "retention": "limits", "mirror_direct": false }

带附加选项

{ "name": "MIRROR_TARGET" "discard": "old", "mirror": { "opt_start_time": "2024-07-11T08:57:20.4441646Z", "external": { "deliver": "", "api": "$JS.domainB.API" }, "name": "MIRROR_ORIGIN" }, "consumer_limits": { }, "deny_delete": false, "sealed": false, "max_msg_size": -1, "allow_rollup_hdrs": false, "max_bytes": -1, "storage": "file", "allow_direct": false, "max_age": 0, "max_consumers": -1, "max_msgs_per_subject": -1, "num_replicas": 1, "name": "MIRROR_TARGET", "deny_purge": false, "compression": "none", "max_msgs": -1, "retention": "limits", "mirror_direct": false }
ON THIS PAGE