我计划使用Kafka在队列中存储消息，并在特定队列中的消息数量达到某个限制(例如1000)时获取消息。
有没有办法让Kafka服务器在队列达到极限时通知消费者？
浏览 0提问于2014-05-27得票数 1
parsed["LastTimeReportGenerated"])惠特成功了获取错误消息can't convert DateTime into an exact number
正确的语法是什么？
浏览 3提问于2014-10-16得票数 0
回答已采纳
1回答
我有一个交换，并且只有一个队列绑定到它。当消息发布速率超过某个上限时，rabbitmq会自动限制传入消息速率。我的消息不是持久的，所以我没有磁盘限制。在搜索时，我发现说明队列限制为单cpu的文档。
这是什么意思？rabbitmq队列进程是否只使用1个cpu，即使机器中有多个可用
浏览 2提问于2019-07-23得票数 1
4回答
检查队列是否存在
、、
关于Windows存储队列错误/访问，我有一个非常基本的问题。
我试图找出给定的存储帐户是否已经包含了给定名称的队列--比如"queue1“。如果队列不存在，我不想创建它，因此我不想使用CreateIfNotExist方法。我授予SAS令牌的权限正在处理和添加(因为我所要做的只是在队列已经存在时才向队列添加新消息，否则抛出错误)。问题是，当我试图获得一个假的命名队列的引用，并向它添加一条消息时，我得到一个403。403也可能在SAS
浏览 6提问于2013-08-02得票数 1
1回答
它将需要窥视机器上的每个队列。但是，我在使用与DeadLetter和XactDeadLetter系统队列相关的权限时遇到了困难。访问始终被拒绝。我打开“计算机管理”，展开“服务和应用程序”，右键单击“消息队列”，然后单击“属性”。在属性对话框中，我转到Security选项卡，并添加我的域服务帐户user，并指示我要为该用户提供完全控制权限。单击apply后，我将看到以下弹出窗口：当我在弹出窗口上单击ok时，我会得到：我已经研究过手动设置队列的安全性，但似乎系统<e
浏览 5提问于2014-12-27得票数 0
接收线程处于无限时间循环中。当没有要读取的数据时，当数据到达时，它会休眠，然后读取数据，然后将其推入消息队列(全局创建)。我想使用我在加载表单时创建的另一个表单来读取消息队列和更新UI。我想要的是，一旦创建了第二个线程，它就应该进入无限睡眠状态，当读取线程读取了4个或更多消息时，它应该会产生某种信号来唤醒休眠线程。然后，线程处理消息队列，直到其为空，然后返回休眠状态，直到从接收线程接收到另一条消息。
浏览 1提问于2012-12-12得票数 1
1回答
当我将消息放入SQS队列时，它显示消息正在传输中，而我的lambda不能处理消息。us-east-1:5722****:log-group:/aws/lambda/815223_Test:*" }} 当我附加“管理员访问”权限权限时我不确定我错过了哪个权限here.My队列是未加密的。
浏览 15提问于2020-08-12得票数 0
如何在kubernetes中部署kafka、amqp或任何其他向上和向下扩展的消息代理的消息使用者？我的假设是，消费者会运行一个循环来提取信息。当许多消息到达代理队列时，我希望kubernetes创建更多的吊舱，当到达队列的消息太少时，我希望删除一些吊舱。如果当队列是空的时候，任何一个豆荚都会结束，我担心只要队列
浏览 0提问于2018-05-30得票数 2
在负载很重的情况下，当后端的特定任务出现问题时，我们的一个队列可以有多达100万条消息等待处理。注意:我们希望将我们的RabbitMQ服务器托管在kubernetes集群中的一个坞映像中。我们设想一个交换，它会在后面的节点中加载队列之间的平衡模型。但是，我们不清楚的是，如果我们检测到队列已经满了，如何动态地按需添加新队列。
浏览 6提问于2022-04-21得票数 1
回答已采纳
2回答
在Windows工作者角色中处理“紧急”消息的最佳方法是什么？
问题是，如果工作人员睡了2分钟，队列中出现了一条消息，我希望唤醒
浏览 4提问于2012-07-29得票数 0
回答已采纳
这里有一些背景:我们有几个共享Hazelcast阻塞quque的服务实例，该服务主要有两个任务：另一个监视队列的类，只要它有任何项，它就会启动进程(基本上一项可能需要1到2秒的时间处理)how避免在队列中添加重复项，以防任何两个实例同时运行调度程序(例如，如果队列中有'A'，'B‘，instanceA将放置'A'，'D'，肯定会过滤掉A，因为它在<
浏览 4提问于2021-03-07得票数 0
1回答
实际实现使用JMS适配器从IBM队列读取消息以发送推送通知。MFP v8不再提供这种适配器，我想知道用最新版本从队列中读取消息的最佳方法是什么。
谢谢，斯特凡诺
浏览 2提问于2016-07-18得票数 0
回答已采纳
通常，请求会被路由到其中一个副本。但是，如果每个实例在webhook请求出现时都需要采取一些操作，我如何将请求路由到所有副本？或者，当其中一个实例接收到请求时，是否有一种方式将请求传递给其他实例？
浏览 0提问于2018-10-24得票数 0
回答已采纳
寻找有关使用内存缓存服务器发布/订阅特别是wrt高吞吐量系统的建议/专业/缺点(每秒1000次更新)希望能得到一些真实世界的输入！
浏览 3提问于2010-06-03得票数 1
回答已采纳
4回答
如果没有结果，我正在尝试在下拉菜单中显示“无结果”消息。因此，例如，如果我在文本字段中键入"ABCD“，并且没有匹配的实体，则消息"No”。将被展示。当未找到结果时，如何向下拉菜单中添加“无结果”消息？})); label: "No Results." }安德鲁·惠</
浏览 8提问于2013-11-18得票数 27
回答已采纳
在端是否可能有一个DeadLetter队列主题？我们对IBM连接器处理的事件提出了挑战，该连接器处理N个消息数量，但发送N-100消息，其中100条消息是有毒消息。但从下面的博客罗宾莫法特，我可以看到，它是不可能有DLQ的源连接器方面。2Q)是否有人在任何其他源连接器侧使用DLQ ? 3Q)为什么在源连接器侧没有DLQ？
谢谢。
浏览 3提问于2021-05-27得票数 1
1回答
这一定义抓住了马丁·赫尔曼、拉尔夫·默克尔和惠特菲尔德·迪夫的直觉理念，1970年中期的S将密码学与复杂性理论结合起来，产生了新密码学及其所有美丽的应用，多重使用密钥进行文件加密、数字签名、数字支付系统、单向函数、单向陷阱函数、抗碰撞散列、消息摘要编码等等。
浏览 0提问于2017-04-25得票数 0
1回答
处理服务器端长轮询的最佳方法
、、、、
我有一个用例，需要每1秒轮询API (基本上是无限时间循环)。轮询将由用户通过外部系统动态启动。这意味着可以同时运行多个轮询。当API返回400时，将完成轮询。使用烧瓶端点的会将消息添加到队列中，工作人员一收到消息，它就会开始轮询。我正在使用Heroku Redis去添加。在引擎盖下，它使用python和redis。问题是当某个轮询过程持续很长时间时，另一个进程就会出现在队列中。我希望能够在并发进程中完成所有轮询。如果可能有超过100个并发进程呢？
浏览 1提问于2020-01-17得票数 3
我有一个计时器触发器，它使用存储队列(Client.Azure.Storage.Queues) { }
我希望消息在2次重试后不会返回到队列中： "version": "2
浏览 4提问于2022-01-19得票数 0
回答已采纳
4回答
使用下面的代码，我可以使用我的AWS帐号添加一个权限，但是队列不接收来自SNS的任何消息。addPermissionRequest.AWSAccountId.Add(AWS_ACCOUNT_ID);但是，当我试图通过通配符(*)为每个人设置权限时如果我在AWS控制台中手动添加权限并指定ReceiveMessage
对于允许的操作和原则，我将其设置为"everybody"，队列确实接收来自我的SN
浏览 9提问于2013-10-12得票数 8
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
