原因:测试kafka时,启动项目报错。
解决办法:在调用测试方法的层,看一下yml文件里有没有加入kafka的相关配置:
配置如下:
kafka:
bootstrap-servers: 192.168.200.130:9092
consumer:
group-id: ${spring.application.name}-kafka-group //**如果其他加了,这个不加,也会报错
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer


