问题标签 [nats-streaming-server]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
nats.io - NATS Streaming Server 在使用集群时被关闭
我有在 3 个虚拟机上运行的 Nats 流服务器，它们按照官方 NATS 文档教程进行集群。每次文件发生更改时，一个实例都会关闭，然后所有其他实例都会在片刻后关闭。
尝试更改一些配置文件但没有成功
例如：有人通过在 VM-1 上连接发布，VM-1 获取消息... 片刻之后（可能是在存储消息时）我在一个实例上收到此错误，然后在其他实例上出现同样的错误。
kubernetes - 如何获取 NATS 流队列的大小？
背景：我将使用 OpenFaaS（在 Kubernetes 中运行）进行一些实验，其中我将调用几个异步执行请求。OpenFaaS 使用 NATS Streaming 将这些请求排队以执行异步函数。
我需要的是一种方法来确定这个 NATS 流队列的大小，这样我就可以知道队列中有多少项目。是否有获取 NATS 流队列中项目大小或数量的命令？我搜索了 Google 和 NATS 文档，没有发现任何用处。
我确实kubectl logs deployment/queue-worker -n openfaas从这里找到了显示队列日志的命令；但是，这并不是我想要的（我想要队列中剩余的项目数，而不是队列的完整日志）。
nats-streaming-server - 是否可以将 SQL Server 用作 NATS 流服务器的数据库存储？
我计划创建一个 nats 流服务器并将 SQL Server 用作数据库存储。那可能吗？
我不确定要在数据库存储配置中添加什么
streaming - NATS-Streaming 记录和重新流式传输频道消息
我想记录由 NATS 流媒体通道流式传输的消息，并在需要时再次流式传输。
我想创建基础设施来测试我的微服务应用程序。所有微服务都使用 NATS 流相互通信，我想“记录”数据流，清理我的数据库并再次流式传输以测试系统是否一致。
我看到有文件存储或 SQL 存储的配置，但两者都用于存储 NATS 的当前状态，如文档中所述。此外，我没有找到“再次流式传输”该数据的方法。
有什么办法吗？
谢谢！
istio - 如何在 Istio 中的一个服务边车与 NATS 集群之间连接
我创建了一个没有注入 Istio 的 NATS 集群。
现在我有一个 sidecar istio，连接到上面的 Nats 集群，但似乎 istio 断开了连接。我的应用程序上的 nats 客户端关闭，并且 Nats 服务器通知：“客户端解析器错误，状态 = 0 ...”原因是 nats 集群和 sidecar 之间没有 mtls？我该如何解决这个问题？
siddhi - 在 Siddhi 中获取 NATS 流事件序列号
我有一个文本格式的推文流（TwitterStream）和每条推文的情感流（SentimentStream）。SentimentStream 订阅 TwitterStream，进行情绪分析并发布一条带有结果和 TwitterStream 序列号的新消息。
我正在尝试加入这两个流，其中 SentimentStream.seq 等于推文的序列号。我遇到的问题是我无法从 TwitterStream 获得序列号的“句柄”。
我一直在尝试找到一种方法来获取事件“元数据”，这可能会对事件的位置/序列号提供一些见解。
任何帮助将不胜感激。
linux - 如何在不停止流媒体服务器的情况下热重载 NATS 流媒体服务器？
我在 docker 容器中运行 nats 流服务器，我想在不停止 nats 流服务器的情况下重新加载 nats 特定配置。有没有办法这样做？
go - NATS 流式“StartAt”订阅选项
与其他人（例如等）相比，我对StartAt订阅选项的要求/意义感到有些困惑。StartAtSequenceStartWithLastReceived
我试图深入研究 Java 客户端文档，但这也无济于事 - 例如无法设置选项，但它是可获取的
输入赞赏！
node.js - 如何在 Docker 中将 NATS 服务器连接到 NodeJS 应用程序
我有一个连接到 NATS 服务器的节点应用程序。下面是两个服务器的 docker-compose.yml。
上面的 nodejs 片段给了我：
NatsError：无法连接到服务器：错误：getaddrinfo ENOTFOUND nats-server
如果我使用let nats = NATS.connect()它会给我：
NatsError：无法连接到服务器：错误：连接 ECONNREFUSED 127.0.0.1:4222
请就如何解决此问题向我提出一些想法。谢谢。
java - Messages order for 2 different subscriptions
I have following (simplified) setup
Consumer (single threaded, streamingConnection is singleton)
Producer (single threaded, streamingConnection is singleton)
- Publishes message to Topics.OUTPUT_ORDER
- Publishes message to Topics.OUTPUT_TRANSACTION
Is nats streaming garantees, that consumer receives and handles messages in the same order? I have order id in transaction payload and I must know the id before transaction processing.
From nats java library description:
The new version minimizes threads. Only one thread is used for all callbacks, by relying on a dispatcher in the underlying NATS connection.
If there is only one thread, Topics.OUTPUT_TRANSACTION processing on consumer will be blocked until Topics.OUTPUT_ORDER onMessage() handler finishes. Am I right?