Spring boot 项目Kafka Error connecting to node xxx:xxx Kafka项目启动异常 Failed to construct kafka consumer

末蓝、 2024-04-01 11:08 88阅读 0赞

## 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][win_host]  
mac用户可以下载ihost软件来编辑hosts文件  
在文件最下面追加自己对应的ip 和计算机昵称即可

192.168.0.11 node1
    192.168.0.12 node2
    192.168.0.13 node3

![在这里插入图片描述][c5feeb3f3bae466ab608c4efa40510d8.png]  
之后再重启项目即可。  
修改完hosts之后可能不是立即生效，可以断一下网再重新连接。

[win_host]: https://product.pconline.com.cn/itbk/software/dnwt/1511/7176461.html
[c5feeb3f3bae466ab608c4efa40510d8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/75503f4fdcdb4a98a7205e5e779de947.png