您的第一个问题：

有没有一种方法可以让消费者自动重新连接到服务器，而不需要重新启动整个应用程序？我错过了一些配置选项吗？
Kafka brokers / clients（v2.3）中引入的静态成员资格选项将缓解此行为，您需要做的所有配置如下所示“从文档链接关于”
基本上，静态成员身份特性所做的是，每当消费者线程加入一个组时，它将获取一个group.instance.id，因此在此消费者示例中（线程）出于任何原因离开组，这将不会触发整个消费者组上的重新平衡，然而，连接到该（死的）消费者线程的分区将是空闲的，并且没有处理发生，直到该X1 M1 N1 X再次恢复活动。

• 将代理集群和客户端应用程序都升级到2.3或更高版本，同时确保升级后的代理使用的是2.3或更高版本的inter.broker.protocol.version。
• 对于一个组下的每个使用者示例，将config ConsumerConfig#GROUP_INSTANCE_ID_CONFIG设置为唯一值。
• 对于Kafka Streams应用程序，为每个KafkaStreams示例设置唯一的ConsumerConfig#GROUP_INSTANCE_ID_CONFIG就足够了，与示例使用的线程数无关。

我建议阅读这篇article文章，以获得有关静态成员资格与动态成员资格的更多详细信息

对于您的第二个问题：

我尝试实现Spring运行状况检查，因此应用程序将报告
是的，如果您使用Kafka-Streams API，则可以将StateListener注册为以下示例

streams.setStateListener((KafkaStreams.State newState, KafkaStreams.State old)->{
                logger.info()
                        .message("Thread state has changed from {" + old.name() + "} to {" + newState.name() + "}")
                        .log();
                // Here you can set any global state that you can expose via api and enquire on it using K8S health check.
                }
            });