zl程序教程

您现在的位置是:首页 >  其他

当前栏目

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

2023-04-18 16:29:01 时间

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:WindowsSystem32driversetc 目录 找到hosts文件,编辑这个文件 :win修改host
mac用户可以下载ihost软件来编辑hosts文件
在文件最下面追加自己对应的ip 和计算机昵称即可

192.168.0.11 node1
192.168.0.12 node2
192.168.0.13 node3

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