Solace JMS消费者在重新连接后停止
我在项目中使用solace作为JMS提供者。我使用spring CachingConnectionFactory检索连接。在这个连接上，我创建了一个新会话。我在那个会话中创建了一个消费者的线程。
@Autowired
CachingConnectionFactory ccf;
Connection connection = ccf.createConnection();
Session session = connection.createSession(true, Session.SESSION_TRANSACTED);
MessageConsumer messageConsumer = new session.createConsumer(destination); // This is passed to new thread
我正在做一些故障转移测试。当我将服务器从网络连接上拔下时，它会失败。当我再次连接服务器时，仍会收到相同的异常：
javax.jms.IllegalStateException: Error receiving message - already closed (Tried to call receive on a stopped message consumer.) ...
更重要的是，CachingConnectionFactory默认将reConnectOnExcture属性设置为true（我检查了是否有效）。
例外似乎很清楚。所以我的问题是：当连接丢失并再次建立时，如何处理这种情况/异常？消费者有可能再次活着吗？或者我应该创建新的消费者和新的线程（我想避免什么）？
共有2个答案
一般来说，CachingConnectionFactory可以通过Connection的onExc0019（）支持自动重新连接。但是一旦连接被重新连接，您使用的消费者也应该被重新创建。
您可以参考/使用spring的DefaultMessageListenerContainer或SimpleMessageListenerContainer，例如，SimpleMessageListenerContainer：
ReconnexException属性将在收到异常后尝试重新连接。由于故障切换仍在进行中，此重新连接可能会失败。
您可以将Solace API配置为尝试使用JNDI连接工厂中的“重新连接重试”和“重新连接重试等待”属性重新连接多次。这可以在Solace路由器上通过SolAdmin或CLI进行配置。如果将应用程序配置为重新连接足够长的时间以建立连接，则不应该遇到任何异常。否则，您将需要在收到此异常时再次创建会话和消费者。
-
但是，即使我将节点显式设置到属性中，它们也不会尝试重新连接到有效的kafka节点。 如何使我的使用者在他们连接的kafka节点失败后重新连接到有效的kafka节点？
-
我有一个简单的Kafka设置。生成器正在以较高的速率向单个分区生成具有单个主题的消息。单个使用者正在使用来自此分区的消息。在此过程中，使用者可能会多次暂停处理消息。停顿可以持续几分钟。生产者停止产生消息后，所有排队的消息都将由使用者处理。生产者产生的消息似乎不会立即被消费者看到。我使用的是Kafka0.10.1.0。这里会发生什么？下面是使用消息的代码部分： 代理上的所有配置都保留为kafka默认
-
我需要帮助消费者在Spring启动。当断开连接时，我需要停止应用程序，例如10分钟。当断开连接时 或者当无法连接时 我使用ConsumerFactory和ConcurrentKafkaListenerContainerFactory进行消费者的所有配置
-
我们有一个制作人 在开发过程中，我重新部署了producer应用程序，并做了一些更改。但在此之后，我的消费者没有收到任何消息。我尝试重新启动消费者，但没有成功。问题可能是什么和/或如何解决？ 消费者配置： 生产者配置： 编辑2： 5分钟后，消费者应用程序死亡，但以下情况除外：
-
我正在使用这个库来实现节点kafka与消费者暂停和恢复方法来处理背压。我已经创建了一个小演示，我可以在其中和，但问题是在后它停止了消费消息。 这是我的代码。 任何人都可以帮助我，我在恢复消费者时做错了什么？当我启动使用者时，它只接收一条消息，并且在恢复后仍然不消耗任何其他消息。
-
我想在远程位置检查Kafka消费者的连接。 可以确定是否将使用者分配给分区。 在远程位置，我可以从Kafka代理获得有关该主题的详细信息。 但是消费者能否保证消费者能够收到消费者与主题分区匹配的消息？