我有一个应用程序，该应用程序在特定主题下向Pulsar生成消息，并在该应用程序完成后关闭该应用程序；同时，不存在用于读取该主题的使用者。过了一段时间，当我创建一个使用者并想要读取写入的数据时，我发现所有的数据都丢失了，因为我编写的主题被Pulsar删除了。
如何在Pulsar中禁用非活动主题的自动删除？
浏览 0提问于2019-07-24得票数 4
回答已采纳
雅虎开发了Pulsar，pub-sub消息系统，并使其开源。它现在是Apache的孵化项目。因为Kafka也用于相同的目的。想知道，卡夫卡相对于脉冲星的主要正负点。
浏览 1提问于2017-09-05得票数 56
我正在尝试使用ANSI-C和MQGET函数从队列接收消息。问题是我总是收到error 2010 (MQRC_DATA_LENGTH_ERROR)。我的队列中的消息有7157460字节。我用于MQGET的通道将“最大消息长度”设置为104857600 (以及保存消息的队列)。我应该以某种方式增加MQSERVER环境变量中消息的最大大小吗？
浏览 0提问于2012-11-05得票数 2
回答已采纳
我目前正在将一个相当大的Rails2应用程序转换到Rails3，该应用程序在其插件形式中使用了activemessaging。它与Amazon SQS一起使用，主要用于文件上传，以及其他一些事情。我使用的所有队列都是在messaging.rb中定义的，并且已经有了处理消息的处理器。在Rails3版本中，我切换到了activemesssaging gem，版本0.9.0。我似乎找不到太多关于Rails3和活动消息的信息，所以如果有人能给我我需要做的基本步骤，我将不胜感激。谢谢。
浏览 0提问于2012-04-16得票数 1
回答已采纳
org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction$AsyncShardOperationAction$1@12ae9af；上的EsRejectedExecutionExceptionrejected执行(队列容量
浏览 3提问于2013-12-19得票数 27
回答已采纳
堆栈跟踪使我相信这可能是Windows消息队列的问题。
任何关于什么可能导致这一错误，或如何修复它的想法，都将不胜感激。
浏览 13提问于2011-02-17得票数 26
回答已采纳
4回答
我需要为新项目选择一个新的队列代理。
“消息可以使用具有请求参数(basic.recover、basic.reject和basic.nack)的AMQP方法返回到队列，或者由于通道关闭，同时保存未确认的2.7.0版本和更高版本，如果队列
浏览 10提问于2014-01-26得票数 84
回答已采纳
1回答
用于libcaf的港口手工系统
、、、、
当前的状态是:我有一个大的全局消息队列，我的系统(也就是参与者)订阅这个队列来获取他们的消息。它们以消息响应该全局队列。现在，我的系统不需要知道消息的接收者，因为接收者为他们想要的消息注册。我
浏览 3提问于2016-04-25得票数 3
回答已采纳
通常，当MQTT客户端开始从代理接收超时或其他错误时，消息将存储在持久性存储中(在运行中的消息)，并最终将被重新发布。但是，在泛美卫生组织客户端失去与代理的连接的情况下，消息将不再在运行中被考虑，也不会被泛美卫生组织存储。这时，这个应用程序似乎开始负责维护这些消息(在泛美卫生组织之外)并重新发布它们。
客户端当前正在断
浏览 20提问于2015-01-24得票数 7
1回答
使用将服务与数据库分离？
、、、、
为了使应用程序与数据库完全解耦，过去我使用了service :在运行该服务的每个服务器上，我安装了一个server实例，它实际上只是充当Service消息到核心(SSB "target")数据库的队列。
浏览 1提问于2013-03-08得票数 3
回答已采纳
5回答
我有一个电子邮件服务器，它是消息传递应用程序的一部分，它将看到大量的吞吐量。我希望在RAMdisk上挂载Exim的消息队列，以最大限度地提高性能；吞吐量速度是最重要的，而不是在崩溃或系统重新启动时的团结。我发现很多信息表明，在RAMdisk上挂载消息队列会有很大帮助，但没有关于如何做到这一点的真正信息。我非常确定消息队列默认在/var/spool/exim中，并且可以使用tmpfs挂载RAMdisk。我到底该如何在启动时挂载RAMdisk，
浏览 0提问于2011-05-06得票数 3
3回答
我有一个客户端正在使用任何网络协议向某个软件服务提供商(ABC)发送特定的消息格式。
现在，此客户端正在切换软件服务提供商(XYZ)，但不希望更改其软件，并希望继续发送ABC提供商的相同消息。protocolProvider XYZ在一些古老的网络上使用某种基于位置的消息格式，XYZ使用XML (S) web服务，而不只是简单的，有些值可以直接映射，而其他值必须重新计算或修改。因此，我需要创建某种隧道，接受TCP/IP将消息转换为XML，将HTTP(s) POST发送到XYZ，返回XML响应，转换回基于位置的，通
浏览 4提问于2011-11-17得票数 0
回答已采纳
4回答
我很难找到承诺的用处。下面这两种方法不是用同样的方式吗？由于while循环在loopTest()中是同步的，在它完成之前，logStatement()函数是不会运行的，那么第二种方法又有什么不同呢.等待它到resolve()不是毫无意义吗？function loopTest() { console.log(i) })
console.log("Logging test")
loopTest(
浏览 3提问于2020-12-16得票数 1
回答已采纳
我有一个Azure网络作业，有几个队列触发函数。的SDK文档将MaxDequeueCount属性定义为：
{ }查看webjobs仪表板，我发现SDK进行了5次尝试(5是默认的，如上面所述)：在第五次尝试之后，消息被移动到毒队列中)的特定队列项的详细信息，或者由于异常而失败，并被放置在
浏览 8提问于2017-02-15得票数 10
回答已采纳
4回答
我正在做一个从API中提取数据(JSON)的项目。我遇到的问题是，记忆在缓慢增长，直到我得到可怕的致命错误：
<?php
echo "Start: ". memory_get_peak_usage(true) . " |
浏览 12提问于2015-10-27得票数 11
回答已采纳
2回答
我正在使用SOAP和wsdl2objc生成的代码。我有多个视图控制器，它们需要共享web服务提供的数据。我希望有一个数据模型的部分，但我有一个艰难的时间来看如何处理这一点。当然，这些调用应该是异步的。我的问题是，最好的实践是什么？谁来负责数据的抓取？谁应该存储数据？如何处理并发？任何想法都将不胜感激！
更新:我正在考虑使用CoreData，但不确定当数据频繁更新时会有什么好处。我最大的问题是如何处理这样的场景:视图控制器从模型请求数据，但没有可用的数据。这意味着执行一个缓慢的web服务调用，并在数据进入时以某种方式通知视图控制器。通知中心是去这里的路吗？流程会是怎样的？视图控制器是否应该不断侦
浏览 0提问于2013-02-16得票数 2
回答已采纳
3回答
我尝试为C#寻找现有的websockets，但是它们不适合的原因是Unity3d只能使用.NET 3.5 (最新的Unity3d 2017.1版本中的.NET 4.6 )执行Mono库。
浏览 0提问于2017-09-29得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
