问题标签 [nats-streaming-server]

我有在 3 个虚拟机上运行的 Nats 流服务器，它们按照官方 NATS 文档教程进行集群。每次文件发生更改时，一个实例都会关闭，然后所有其他实例都会在片刻后关闭。

尝试更改一些配置文件但没有成功

例如：有人通过在 VM-1 上连接发布，VM-1 获取消息... 片刻之后（可能是在存储消息时）我在一个实例上收到此错误，然后在其他实例上出现同样的错误。

背景：我将使用 OpenFaaS（在 Kubernetes 中运行）进行一些实验，其中我将调用几个异步执行请求。OpenFaaS 使用 NATS Streaming 将这些请求排队以执行异步函数。

我需要的是一种方法来确定这个 NATS 流队列的大小，这样我就可以知道队列中有多少项目。是否有获取 NATS 流队列中项目大小或数量的命令？我搜索了 Google 和 NATS 文档，没有发现任何用处。

我确实kubectl logs deployment/queue-worker -n openfaas从这里找到了显示队列日志的命令；但是，这并不是我想要的（我想要队列中剩余的项目数，而不是队列的完整日志）。

我计划创建一个 nats 流服务器并将 SQL Server 用作数据库存储。那可能吗？

我不确定要在数据库存储配置中添加什么

我想记录由 NATS 流媒体通道流式传输的消息，并在需要时再次流式传输。

我想创建基础设施来测试我的微服务应用程序。所有微服务都使用 NATS 流相互通信，我想“记录”数据流，清理我的数据库并再次流式传输以测试系统是否一致。

我看到有文件存储或 SQL 存储的配置，但两者都用于存储 NATS 的当前状态，如文档中所述。此外，我没有找到“再次流式传输”该数据的方法。

有什么办法吗？

谢谢！

我创建了一个没有注入 Istio 的 NATS 集群。

现在我有一个 sidecar istio，连接到上面的 Nats 集群，但似乎 istio 断开了连接。我的应用程序上的 nats 客户端关闭，并且 Nats 服务器通知：“客户端解析器错误，状态 = 0 ...”原因是 nats 集群和 sidecar 之间没有 mtls？我该如何解决这个问题？

我有一个文本格式的推文流（TwitterStream）和每条推文的情感流（SentimentStream）。SentimentStream 订阅 TwitterStream，进行情绪分析并发布一条带有结果和 TwitterStream 序列号的新消息。

我正在尝试加入这两个流，其中 SentimentStream.seq 等于推文的序列号。我遇到的问题是我无法从 TwitterStream 获得序列号的“句柄”。

我一直在尝试找到一种方法来获取事件“元数据”，这可能会对事件的位置/序列号提供一些见解。

任何帮助将不胜感激。

我在 docker 容器中运行 nats 流服务器，我想在不停止 nats 流服务器的情况下重新加载 nats 特定配置。有没有办法这样做？

与其他人（例如等）相比，我对StartAt订阅选项的要求/意义感到有些困惑。StartAtSequenceStartWithLastReceived

我试图深入研究 Java 客户端文档，但这也无济于事 - 例如无法设置选项，但它是可获取的

输入赞赏！

我有一个连接到 NATS 服务器的节点应用程序。下面是两个服务器的 docker-compose.yml。

上面的 nodejs 片段给了我：

NatsError：无法连接到服务器：错误：getaddrinfo ENOTFOUND nats-server

如果我使用let nats = NATS.connect()它会给我：

NatsError：无法连接到服务器：错误：连接 ECONNREFUSED 127.0.0.1:4222

请就如何解决此问题向我提出一些想法。谢谢。

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?