当Kafkabroker变得不可用时,我的spring boot 2.1.5消费者应用程序宕机,异常如下。它使用的是spring-kafka 2.2.6。我需要我的应用程序保持运行,并在kafkabroker回来后继续消费。';
nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetchingtopic m
我们使用的是kafka-streams 2.3.1,我刚刚注意到,如果broker宕机,streams应用程序似乎满足于尝试永远保持连接。new KafkaStreams(createTopology(), properties()).start() o.apache.kafka.clients.NetworkClient - [AdminClientclientId=test] Connection to node -1 (broker/127.0.0.1:9092) could not b