gpt4 book ai didi

java - Spring Kafka - 代理重新连接事件

转载 作者:行者123 更新时间:2023-12-01 23:05:47 26 4
gpt4 key购买 nike

我正在我的应用程序中测试 Kafka 代理关闭场景。如果 Kafka 代理关闭,我的应用程序中会收到 NonResponsiveConsumerEvent 事件,就像我恢复 Kafka 代理一样,是否有任何事件或任何内容可以用来通知用户已成功重新连接?

最佳答案

当代理关闭时,消费者不再阻塞,因此该事件现在可能永远不会被发布。您可以启用容器空闲事件并使用 AdminClient 检查状态。

Example in this answer .

关于java - Spring Kafka - 代理重新连接事件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58401358/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com