问题标签 [nsq]

什么 我正在使用 4 个消费者从 NSQ 服务器消费消息。我正在尝试调试我看到backing off日志的原因，因为我的消费者在发生这种情况时会放慢速度。

我正在记录异常，那是我返回 aFalse以重新排队消息的时候。我没有看到任何异常被记录，但我一直看到这条消息。帮助！！

代码

此错误发生在pynsq 0.4.2

堆栈跟踪

代码

什么：

有人可以帮助我理解此错误消息的含义。nsqadmin显示很多消息正在重新排队/超时。这些日志可能是原因吗？

我在用pynsq 0.4.2

堆栈跟踪

代码

是否可以使用Docker复制“拓扑模式”的最后一个示例中描述的“NSQ 实时分布式消息传递平台” ？有人有 dockerfile 或图像示例吗？

在go-nsq库（https://github.com/bitly/go-nsq/blob/master/writer_test.go#L38）中，我找到了以下代码：

为什么作者在丢弃日志后将日志记录推迟到标准输出？

我正在尝试使用 nsq 作为ELK 堆栈的代理。

我正在考虑通过让nsq通过 REST api将数据发送到elasticsearch来做到这一点。根据该文档，我可以发出 HTTP PUT 请求以将数据添加到弹性搜索。

但是，根据 nsq文档，nsq 只能通过 nsq_to_http 实用程序发出 POST 或 GET 请求。我无法发出弹性搜索所需的 PUT 请求。如何将值从 nsq 传递到 elasticsearch？

我正在尝试连接这 2 个 docker 容器：

nsqd：https ://registry.hub.docker.com/u/mreiferson/nsqlookupd/ nsqlookupd：https ://registry.hub.docker.com/u/mreiferson/nsqlookupd/

这些是 nsqd 和 nsqlookupd 的官方 docker 容器。

问题是当我在 nsqd 中创建主题时，我在 nsqlookupd 中看不到该主题。

IE

我像这样启动我的 2 个容器（172.17.42.1 是我的 docker 主机 IP）：

我显然错误地连接了 2 个容器。我将如何正确连接它们？

这里有点菜鸟，但我似乎无法在任何地方找到任何示例或帮助。我有一个 NSQ 的工作实例，可以注册任务、消费者等。不幸的是我最初没有设置系统。我要做的是弄清楚如何激活 NSQ 提供的一些内置命令行工具（nsq_to_file、nsq_tail 等）。我找到了关于如何解雇他们的文档，但不知道从哪里解雇他们。

当我尝试时，nsq_tail --channel=MyTestChannel --topic=test --lookupd-http-address=127.0.0.1:4161找不到 nsq_tail 命令。我唯一知道的另一件事是，在我们的情况下，NSQ 是由 docker 管理的。任何朝着正确方向的帮助/推动都会很棒。谢谢！

我下载并构建了 nsq src 代码，我想通过 intellij 14.0 golang 插件浏览 src 代码。如何将整个 nsq 项目导入 intellij 而不会出错？

我是来自 Node 世界的 Go 新手，我正在使用官方 Bitly Go 客户端构建消费者。我正在使用 AddConcurrentHandlers 生成 50 个 goroutine 来处理消息的消防软管。问题是我的消费者落后于在 nsq 上留下指数级的未处理/接收到的消息。有人遇到过这种情况么？

我在 Node 中构建了相同的东西，以查看是否存在服务器或 NSQ 配置问题，以及它是否能够尽快处理所有消息。

去代码：