如果我的生产者生产，那为什么消费者不能消费?它卡住了@ poll()
我正在发布到远程 kafka 服务器并尝试使用来自该远程服务器的消息.(卡夫卡 v 0.90.1)发布工作正常，但消费也不行. 出版商 package org.test;导入 java.io.IOException;导入 java.util.Properties;导入 org.apache.kafka.clients.producer.KafkaProducer；导入 org.apache
..
jms-topic相关内容
获取关联 ID 为 1 的元数据时出现警告错误:{MY_TOPIC?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient)
当我使用 kafka 0.9.0.1 运行以下命令时，我收到此警告 [1].你能告诉我我的主题有什么问题吗?(我正在与在 ec2 中运行的 kafka 代理交谈) #./kafka-console-consumer.sh --new-consumer --bootstrap-server kafka.xx.com:9092 --topic MY_TOPIC? [1] [2016-04-06
..
计算存储在 kafka 主题中的消息数
我使用的是 0.9.0.0 版本的 Kafka，我想在不使用管理脚本 kafka-console-consumer.sh 的情况下计算主题中的消息数. 我已经尝试了答案中的所有命令 Java，如何在 apache kafka 中获取主题中的消息数但没有一个产生结果.有人可以帮我吗? 解决方案 您可以尝试执行以下命令: bin/kafka-run-class.sh kafka.too
..
如何检测 JMS 主题连接丢失
我们有连接到服务器进程的摆动 GUI 客户端. 客户端使用 jms:queue 'from' 在 Camel 路由中定义的端点'调用'服务器上的服务，并使用 ActiveMQ 作为底层 JMS 代理. 但是，客户端还提供了一个 Camel jms:topic 端点，供服务器将消息广播回客户端. 不幸的是，主题连接似乎以某种方式丢失了，尽管客户端仍然可以“调用"服务器上的服务，但服
..
如果我的生产者在生产，那为什么消费者不能消费?卡住了@ poll()
我正在发布到远程kafka服务器，并尝试使用来自该远程服务器的消息.(卡夫卡v 0.90.1)发布工作正常，但也不费劲. 发布者 package org.test;导入java.io.IOException;导入java.util.Properties;导入org.apache.kafka.clients.producer.KafkaProducer;导入org.apache.kafka
..
如何从Java程序创建对ibm mq amqp主题的持久订阅?
我们通过提供 clientId 和订户名称，使用 createDurableSubscriber 以编程方式创建了IBM MQ AMQP主题的订户. 我们启动了程序，因此它订阅了TOPIC并停止了该程序.然后将msg发送到主题，然后再次启动接收器程序，但是我们无法接收已发送的msg，并释放消息(如果持久订阅则不会发生此消息). 使用mqsc命令连接订户时，我们可以看到amqp主题及其持
..
具有多个代理的JMSTemplate.目标解析异常
我遇到了一整天都在努力解决的问题，但是没有成功... 我有一个应用程序试图与外部系统A和外部系统B之间收发消息.A和B是基于WLS的外部系统. 我的应用程序即将发布时-我正在读取所有配置并构建我的应用程序JMSProducer，并在其中注入具有预定义目标名称的JMSTemlate. 这是我的代码: private JMSProducer initProducer(Conf con
..
计算存储在kafka主题中的消息数
我正在使用0.9.0.0版本的Kafka，并且我想在不使用管理脚本kafka-console-consumer.sh的情况下计算主题中的消息数. 我已经尝试了答案 解决方案 您可以尝试执行以下命令: bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092,localhost:909
..
每个主题在集群中运行的每个侦听器仅消耗一次消息
我正在实现域事件基础结构，但是该项目不允许任何消息传递基础设施(金融服务客户端)，因此在Hazelcast Topics和ExecutorService中找到了替代方法， 但是问题是，当在集群中运行时，消息将传递给将在集群中运行的侦听器，因此对于集群2，我们在2个jvm中运行了相同的侦听器，并且消息消耗了两次并采取了行动，假设Domain事件应该执行一些非幂等的操作，例如为某些忠诚度积分打分
..
HornetQ JMS主题到主题的桥梁
我正在尝试在两个主题之间架起一座桥梁.这个想法是这样的: 通知被发布到HornetQ服务器A上的某个主题 此通知已发送到HornetQ服务器B上的某个主题(通过 桥?) 客户端应用从服务器B获取通知. 我需要这样做的原因是，如果服务器B关闭，我们仍然希望该主题启动，并最终传递给订阅服务器. 我需要的是一个演示hornetq-configuration.xml和hornetq-
..
JMS 2.0-如何从共享使用者那里接收来自主题的消息?
我正在使用ActiveMQ Artemis和JMS 2.0来与共享使用者一起阅读主题消息.我有两个问题: 有什么方法可以使用xml格式的配置. 当我在使用者上设置消息侦听器时，是否必须使用while循环?如果我不使用while (true)循环，则当主题没有消息时，程序将终止. SharedConsumer.java public class SharedConsumer {
..
spring jms如何在持久主题侦听器之间分发消息?
原始jms代码: TopicSubscriber durSubscriber1 = receiverSession.createDurableSubscriber(topic,"subscription_1"); durSubscriber1.setMessageListener(new MessageListener() { @Override public void on
..
如果我的生产者在生产，那为什么消费者不能消费?卡住了@ poll()
我正在发布到远程kafka服务器，并尝试使用来自该远程服务器的消息. (卡夫卡v 0.90.1) 发布工作正常，但也不费劲. 发布者 package org.test; import java.io.IOException; import java.util.Properties; import org.apache.kafka.clients.producer.KafkaProd
..
提取具有关联ID 1的元数据时发生警告错误:{MY_TOPIC?= INVALID_TOPIC_EXCEPTION}(org.apache.kafka.clients.NetworkClient)
当我使用kafka 0.9.0.1运行以下命令时，收到此警告[1].您能告诉我我的主题有什么问题吗? (我正在与在ec2中运行的kafka经纪人交谈) #./kafka-console-consumer.sh --new-consumer --bootstrap-server kafka.xx.com:9092 --topic MY_TOPIC? [1] [2016-04-06
..
具有多个实例的群集中的JMS持久订阅者
我将使用Payara BTW .... 假设我有： JMS主题 配置为持久主题订阅者的MDB 在群集中部署了多个MDB实例，它们都使用相同的客户端ID值来进行持久订阅。 如果是这种情况，并且考虑到客户ID值和持久订阅的工作方式，那么它是更正确的说，群集中只有一个MDB实例会成功连接，其他实例会失败吗？ 谢谢！ 假设您已将MDB部署到群集，因此跨多个MDB实
..
防止线程在java中重复处理
问题陈述 我有一个 JMS 监听器作为一个主题收听的线程运行。一旦收到消息，我就会生成一个新的 Thread 来处理有界消息。因此，对于每个传入的消息，我产生了一个新的线程。 我有一个场景，当重复消息在顺序注入时也会被处理订购。我需要防止这个被处理。我尝试使用 ConcurrentHashMap 来保存处理时间，只要 Thread 生成并删除，我就会在该处理中添加它很快从地图线程完成执
..
如何在Spring Jms Tibjms中在多个VM之间共享主题上发布的消息
我的应用程序正在使用发布到主题的消息。我有3台运行我的应用程序代码的服务器。通过当前实现，消息被分发到所有正在运行的VM，即每个消费者都接收消息的副本。 我的要求是每个消费者都应该收到不同的消息即没有两个消费者应该得到相同的消息。 以下是我正在使用的库： spring jms 4.2.7 Java jms 2.0 tibco jms 8.0 wildfly-swarm as
..
如何从持久主题订阅退订
使用践踏的WebSockets连接到服务器的ActiveMQ，我extjs5浏览器的Web应用程序有许多主题订阅范围，以面板。 下面是一个主题订阅与头部的例子： VAR子= this.mqClient.subscribe（'/主题/状态“，this.onStatusMsg， {“确认”：“自动”，“老大难”：真的，“activemq.retroactive”：真实的“选择”：“任务id =
..
如何检测JMS主题连接丢失
我们有一个连接到一个服务器进程Swing GUI的客户。 客户的呼叫'使用 JMS服务器上的服务：队列'的'骆驼路线定义端点，并使用ActiveMQ的作为底层JMS代理 但是，客户端还提供了一个骆驼 JMS：题目终端服务器广播消息返回给客户端 不幸的是，它看起来像主题连接是越来越不知何故而丢失，虽然客户仍可以“呼叫”服务器上的服务，服务器无法发送任何信息到客户端的话题终结点。 骆驼端点的客
..