Aysnc ActiveMQ消息消费者无法消费消息
我在ActiveMQ中使用异步消息使用者。我的制作人工作正常，向队列发送消息。现在，我的异步消息消费者正在等待调用onMessage（），但这从未发生过。因此，问题是：
- 异步使用者不会使用消息
ActiveMQ日志的快照还显示了许多刚刚堆积在挂起状态中的消息：
2015-08-31 09:54:45,331 | DEBUG | queue://SampleQ1, subscriptions=0, memory=0%, size=517, pending=0 <b>toPageIn</b>: 78, Inflight: 0, <b>pagedInMessages.size</b> 439, <b>pagedInPendingDispatch.size</b> 438, enqueueCount: 529, dequeueCount: 12, memUsage:2971237 | org.apache.activemq.broker.region.Queue | Queue:SampleQ1
我想不出问题到底出在哪里。
计数：
- toPageIn 78
只是不断增加，信息仍然无法传递给消费者。
是服务器端问题还是客户端问题？
共有1个答案
浏览ActiveMQ错误列表时，发现了一个与我所经历的非常相似的错误。
https://issues.apache.org/jira/browse/AMQ-2955
总之，我的队列无法在随机实例中及时将消息传递给异步消费者。一旦发生此事件，我发现挂起的消息中有大量消息，排队的消息数与出列的消息数不匹配。
kahaDB的链接讨论中提到的错误，持续存储处于某种不一致的状态，导致消息传递停止。如错误分析中所述，ActiveMQ中的ActiveMQ配置。xml解决了这个问题。
<!--policyEntry queue=">" producerFlowControl="false" memoryLimit="1mb" useCache="false">
</policyEntry-->
-
我有一个简单的Kafka设置。生成器正在以较高的速率向单个分区生成具有单个主题的消息。单个使用者正在使用来自此分区的消息。在此过程中，使用者可能会多次暂停处理消息。停顿可以持续几分钟。生产者停止产生消息后，所有排队的消息都将由使用者处理。生产者产生的消息似乎不会立即被消费者看到。我使用的是Kafka0.10.1.0。这里会发生什么？下面是使用消息的代码部分： 代理上的所有配置都保留为kafka默认
-
我正在尝试让 kafka 消费者获取在 Java 中生成并发布到主题的消息。我的消费者如下。 consumer.java 当我运行上面的代码时，我在控制台中什么也看不到，屏幕后面的java producer程序正在‘AATest’主题下不断地发布数据。另外，在动物园管理员控制台中，当我尝试运行上面的consumer.java时，我得到了以下行 此外，当我运行指向 AATest 主题的单独控制台使用
-
我有一个springboot消费者应用程序。当我第一次运行它时，它消耗了来自Kafka主题的信息。但当我再次运行它时，它停止了消耗。在日志中，我看到以下消息。 我知道消费者无法获得偏移量。在这种情况下，消费者将引用自动偏移重置属性。如您所见，我已将其设置为，希望消费者从头开始阅读。但它没有。 应用程序. yml 在我的Java课上 我尝试了一些东西。 我将值设置为。不出所料，它抛出了一个异常，抱怨
-
有什么方法可以阻止Kafka的消费者在一段时间内消费信息吗？我希望消费者停止一段时间，然后开始消费最后一条未消费的消息。
-
是否有一种方法以编程方式访问和打印使用者滞后偏移，或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视，我应该在上面添加哪些语句来得到滞后偏移值？
-
由于它是一个Spring Boot应用程序，默认偏移量设置为Latest。我在这里做错了什么，请帮我弄明白。