问题描述
我有一个 Quarkus 应用程序，并使用 Kafka Small Rye 反应式消息传递作为我的 Kafka 消费者。当我的 kafka 集群离线并且当我启动我的应用程序时，quarkus 应用程序会出错并停止应用程序。无论如何，我们是否可以对其进行配置，使其在启动期间尝试重新连接而不是提前关闭？
2020-11-16 12:05:28,601 WARN [org.apa.kaf.cli.NetworkClient] (kafka-admin-client-thread | adminclient-1) [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) Could not be established. broker may not be available. 2020-11-16 12:05:29,410 INFO [org.apa.kaf.cli.adm.int.AdminMetadataManager] (kafka-admin-client-thread | adminclient-1) [AdminClient clientId=adminclient-1] Metadata update Failed: org.apache.kafka.common.errors.TimeoutException: Call(callName=fetchMetadata,deadlineMs=1605524729409) timed out at 1605524729410 after 1 attempt(s) Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. 2020-11-16 12:05:29,773 INFO [org.apa.kaf.cli.adm.int.AdminMetadataManager] (kafka-admin-client-thread | adminclient-1) [AdminClient clientId=adminclient-1] Metadata update Failed: org.apache.kafka.common.errors.TimeoutException: Call(callName=fetchMetadata,deadlineMs=1605524759410) timed out at 9223372036854775807 after 1 attempt(s) Caused by: org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has exited.
它与此 issue 类似，但相反（应用应保持在线并不断重试，而不是在应用启动期间 kafka 代理离线时关闭）
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）