春靴与Kafka：如何处理经纪人不可用？
当spring-boot应用程序运行时，如果我完全关闭代理程序（包括kafka和zookeeper)，我会在控制台中看到这个警告，持续很长时间。
[org.springframework.kafka.kafkalistenerendpointcontainer#0-0-c-1]警告o.apache.kafka.clients.networkclient-[Consumer clientid=consumer-1,groupid=responsereceiveConsumerGroup]无法建立到节点2147483647的连接。代理可能不可用。
在Spring Boot中有没有一种方法可以优雅地处理这一点，而不是在控制台上无限的日志？
共有1个答案
增加reconnect.backoff.ms属性（请参阅Kafka文档）。
默认值仅为50ms。
-
我在Windows子系统Linux上安装了kafka，并开始使用命令服务启动，所有服务都已启动。现在，当我尝试从Windows运行我的kafka-spring应用程序时，它显示以下错误：- 无法建立与节点-1（localhost/127.0.0.1：9092）的连接。经纪人可能不可用。 我的服务器属性是：- 我哪里出错了？？？
-
问题内容： 我有以下结构： 通过kafka-topics shell脚本创建了具有复制因子3和分区3的主题。 并使用组localConsumers。领导没事的时候工作正常。 消费者日志 但是，如果领导者倒下了-我在消费者中遇到了错误（systemctl stop kafka）： 节点3不可用。好 消费者日志 使用者无法连接，直到领导者掉线或与另一个使用者组重新连接。 不明白为什么会这样？消费者应重
-
我试图连接到Kafka服务器使用SpringKafka客户端 我正在使用logback。xml。下面是配置。在测试之前，我对Kafka主机和端口进行了硬编码。相同的代码和配置适用于其中一个环境。
-
我想在我的spring boot项目中使用Kafka Streams实时处理。所以我需要Kafka Streams配置，或者我想使用KStreams或KTable，但我在互联网上找不到示例。 我做了制作人和消费者现在我想流实时。
-
我正在尝试仅为代理间kerberos配置Kafka代理。然而，由于它似乎也想通过Kerberos连接到Zookeeper，所以我似乎总是遇到错误。我目前还没有设置任何Zookeeper键。 我的Kafka代理 JAAS 配置如下： 服务器属性 我用上述配置得到的错误如下： 换句话说，我只想要经纪人到经纪人的 kerberos 和经纪人 - 动物园管理员的普通SASL_SSL。这可能吗？
-
我做了一个像这个样例一样的项目。所以控制器是这样的 我喜欢处理所有的可抛物，并做出我定制的统一响应。问题是我找不到一个指南或样本来正确地做这件事。 我搜索了这个错误，发现了这个错误，我没有在我的项目中使用，因为我提供了上面的示例。所以我一无所知。主要的问题是如何处理所有的可抛物，但是如果您能给我一些关于如何解决问题的建议，我将非常感激。