我正在我的应用程序中测试Kafka broker down场景。如果Kafka broker宕机,我的应用程序中会出现NonResponsiveConsumerEvent事件,如果我带回我的Kafka broker,是否有任何事件或任何东西可以用来通知用户它已成功重新连接?
发布于 2019-10-16 03:36:10
当代理关闭时,使用者不再阻塞,因此该事件现在可能永远不会被发布。您可以启用容器空闲事件,并通过AdminClient查看状态。
https://stackoverflow.com/questions/58401358
复制相似问题