Spring boot 项目Kafka Error connecting to node xxx:xxx Kafka项目启动异常 Failed to construct kafka consumer-Toy模板网

这篇具有很好参考价值的文章主要介绍了Spring boot 项目Kafka Error connecting to node xxx:xxx Kafka项目启动异常 Failed to construct kafka consumer。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

Spring boot 项目Kafka Error connecting to node xxx:xxx Spring boot Kafka项目启动异常

新建了一个springBoot集成Kafka的项目配置好yml后发现启动失败：

Failed to construct kafka consumer
构造kafka消费者失败

下面是Kafka配置：

spring:
  kafka:
    bootstrap-servers: node1:9092,node2:9092,node3:9092
    producer: # producer 生产者
      retries: 0 # 重试次数
      acks: 1 # 应答级别:多少个分区副本备份完成时向生产者发送ack确认(可选0、1、all/-1)
      batch-size: 16384 # 批量大小
      buffer-memory: 33554432 # 生产端缓冲区大小
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      #      value-serializer: com.itheima.demo.config.MySerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer

    consumer: # consumer消费者
      group-id: javagroup # 默认的消费组ID
      enable-auto-commit: true # 是否自动提交offset
      auto-commit-interval: 100  # 提交offset延时(接收到消息后多久提交offset)

      # earliest:当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费
      # latest:当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，消费新产生的该分区下的数据
      # none:topic各分区都存在已提交的offset时，从offset后开始消费；只要有一个分区不存在已提交的offset，则抛出异常
      auto-offset-reset: latest
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      #      value-deserializer: com.itheima.demo.config.MyDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

node1:9092,node2:9092,node3:9092 是kafka的主机名，我是由之前的旧项目（非springBoot）迁移到新建项目的，所以链接名就直接抄过来了。
我以为是链接出了问题，我就换成ip形式，把node1:9092,node2:9092,node3:9092 换成了192.168.0.10:9092,192.168.0.11:9092,192.168.0.12:9092 ，也就是ip：端口形式，果然异常变了：

Error connecting to node node1:9092
连接到节点node1:9092时出错

但是还是没解决问题，于是搜索最新出现的异常，于是找到了修改ihost的方案：
win系统打开 C:\Windows\System32\drivers\etc 目录找到hosts文件，编辑这个文件：win修改host
mac用户可以下载ihost软件来编辑hosts文件
在文件最下面追加自己对应的ip 和计算机昵称即可

192.168.0.11 node1
192.168.0.12 node2
192.168.0.13 node3

Spring boot 项目Kafka Error connecting to node xxx:xxx Kafka项目启动异常 Failed to construct kafka consumer
之后再重启项目即可。
修改完hosts之后可能不是立即生效，可以断一下网再重新连接。文章来源地址https://www.toymoban.com/news/detail-400103.html

到了这里，关于Spring boot 项目Kafka Error connecting to node xxx:xxx Kafka项目启动异常 Failed to construct kafka consumer的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！