在Spring AMQP中，我们可以在消费者端设置超时吗？我们有一个AMQP消息到达消费者端的用例public class TestListener implements MessageListener {onMessage(Message message) { }
有没有办法让消费
浏览 23提问于2017-02-03得票数 0
是否支持RabbitMQ在某种程度上，我可以定义我的消费者，它有消费相同消息的限制。也就是说，我的客户使用enqueue=true做了一个基本的拒绝。它将无限地继续监听相同的消息。我不是在谈论队列端的TTL。但是对消费者的控制/配置告诉我只想消费它5次，然后将它发送到另一个队列。这是否可以做到呢？
浏览 2提问于2013-08-16得票数 1
2回答
假设我有3个Kafka经纪人，一个动物园管理员，50个生产者，50个消费者和1个主题(testTopic1)。并且所有的消费者都订阅了testTopic1。现在我希望Kafka集群不会同时向消费者发送超过40条消息。剩下的10个将保留在队列中或放弃它。
也许这是Kafka中的负载均衡。我不知道我将如何做这项工作。我是新来卡夫卡的，请帮帮忙。
浏览 17提问于2019-07-14得票数 0
1回答
我想避免从客户端创建一个消费者。否则，任何客户端都可以监听总线上的所有消息，这是一个严重的安全缺陷。有没有办法限制客户端只创建生产者？
浏览 1提问于2016-05-02得票数 0
2回答
当kafka客户端应用程序没有明确设置组id时，消费者组的名称到底是如何创建的，基于什么？我看到在某些情况下，当它包含服务器进程的名称时(比如当使用kafka-console-consumer.sh时，它类似于console- consumer -nnnn)启动了消费者，有时它反映了消费者通过监听器连接而不经过身份验证的事实
浏览 4提问于2019-03-13得票数 0
客户端是Asp.net核心应用程序接口，消费者是windows服务。作为测试异常用例的一部分，如果我停止使用者并使用请求客户端提交来自API的请求，由于没有使用者处理，API得到请求超时异常，这很酷。但是消息位于消费者队列中，当我启动消费者时，它会挑选消息并处理这些东西(将消息发送到外部端点)，然后移到_skipped队列中，因为没有请求客户端监听此消息。谢谢
浏览 26提问于2021-03-05得票数 0
我正在我的笔记本电脑(Debian8)上写一个QT 5应用程序，如果我的手机上有新的短信(OnePlus One，Android5.1)，我想得到通知。我的问题是，当一个新消息出现时，永远不会发出readyRead()信号。为了监视数据流，我使用了wireshark。Wireshark展示了这个事件。那么智能手机会将事件发送到笔记本电脑，而不是将事件发送到启动连接请求的套接字？
我从(地图)规范获得的注册信息
浏览 0提问于2016-07-14得票数 2
回答已采纳
1回答
我将并发消费者配置为5，如何唯一标识每个消费者？编辑2:我的2个侦听器的样例代码订阅了相同的主题，并且都是持久的<e
浏览 2提问于2017-10-03得票数 0
: {}, Partition: {}, Offset: {} ", payload, cr.key(), cr.partition(),消费者端I有两个消费者1.监听字符串消息2.监听json和反序列化到对象
甚至json消息也会被String listener使用。
浏览 0提问于2020-02-13得票数 1
我排除了，它以某种方式与消费者群体有关。因为当我将"release“更改为新的内容时，函数开始再次被触发。所以，我的主要问题是:什么可能是一个问题？我如何才能发现其他函数是否监听相同的消费者组(这很可能是不可能的，但谁知道呢……)？或者，我如何删除所有的消费者？实际上，如何理解为什么我的函数有时不会被触发？
浏览 25提问于2021-02-04得票数 0
1回答
我有这个：使用者启动监听unix域套接字(类似于此)的tcp服务器，客户端(生产者)将连接到它。然而，有一个明显的竞赛条件-现在我只是有一个大约500毫秒的超时等待消费者启动并开始监听连接。我的问题是-有什么事我可以听吗？我想我可以在超时之后轮询和测试连接。有什么同步工具可以用来轮询，看看是否有什么东西在监听unix域套接字？更新#1
因此，在使用者中，我删除/取消文件链接，然后在生产者中开始监听它，如果它不
浏览 0提问于2019-08-01得票数 -1
让一个消费者监听十个分区，还是让十个消费者监听不同的分区？
浏览 64提问于2019-03-21得票数 0
1回答
如何搁置消息队列？
、、、
简化版：详细解释：我使用ActiveMQ将主更新过程从第三方系统的更新中分离出来。
每晚我都会收到一个提要文件，其中可能包含数千个用户更改。由于这是一项关键任务，并且更新第三方的时间不是很敏感，并且由于更新第三方可能需要从同一个表中读取，因此主要进程是批量更新
浏览 3提问于2016-01-20得票数 1
在另一端，我有4个消费者，他们监听相同的队列(循环模式)。我所要做的就是，如果队列中有很多消息，就向每个消费者发送一条消息，并等待他们的响应。
浏览 9提问于2018-01-03得票数 0
我想对不同的消费者使用相同的消费者工厂和消费者监听器容器工厂。如何在消费者工厂中添加或替换1个以上的groupid？这是我的消费者工厂和消费者监听器容器工厂bean。the application.properties************我想在这里设置多个消费者分组
浏览 20提问于2020-11-14得票数 0
; nis = "navbar__inner_scrolled"; mns> hdr) { mn.addClass(mnsels
浏览 0提问于2016-03-08得票数 0
回答已采纳
1回答
我使用了kafka主题模式方法来监听多个客户端的事件。以下是kafka消费者的代码，其中topic名称来自配置文件，后缀具有硬编码值。消费者什么都不听。谢谢
浏览 17提问于2020-02-24得票数 0
有没有办法根据代码的调用来检查读或写计数。例如，假设我有 final ref = Firestore.instance.document('users/uid');
ref.get(); 现在这是一个读取操作，我可以使用 ref.delete() 或 ref.setData(data); 等。 这对于单个操作来说很简单，如果我正在侦听一个Stream，我如何知道我的函数调用正在发生多少读/写操作？
浏览 10提问于2020-04-28得票数 1
回答已采纳
我有一个主题与多个订阅的客户端运行的默认预取。如果其中一个客户端速度很慢，它就会降低其他订阅的客户端的速度。我想为速度慢的用户动态地降低预取限制，但是由于客户端的速度是随机的，所以这需要动态地完成。现在，因为我为每个订阅者都有队列，所以每个客户端都是相互独立的。我将为每个队列设置预取限制。一旦达到该限制，我将删除这些事件。缺点:现在每个队列都需要内存。我在下面为我的用例添加了更多细节：事件产生速度- 100 rps
默认
浏览 1提问于2013-03-16得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
