Spring Kafka - 代理重新连接事件
Spring Kafka - broker reconnect event
我正在我的应用程序中测试 Kafka broker down 场景。如果 Kafka 代理关闭，我会在我的应用程序中收到 NonResponsiveConsumerEvent 事件，如果我带回我的 Kafka 代理，是否有任何事件或任何东西我可以用来通知用户它已成功重新连接？
消费者在代理关闭时不再阻塞，因此该事件现在可能永远不会发布。您可以启用容器空闲事件并使用 AdminClient.
检查状态
.
我正在我的应用程序中测试 Kafka broker down 场景。如果 Kafka 代理关闭，我会在我的应用程序中收到 NonResponsiveConsumerEvent 事件，如果我带回我的 Kafka 代理，是否有任何事件或任何东西我可以用来通知用户它已成功重新连接？
消费者在代理关闭时不再阻塞，因此该事件现在可能永远不会发布。您可以启用容器空闲事件并使用 AdminClient.