ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

kafka 问题集合——The configured groupId is invalid

2022-02-23 15:31:43  阅读:194  来源: 互联网

标签:springboot configured invalid kafka 问题 版本 写法 groupId


1、问题描述:

The configured groupId is invalid

字面意思,kafka消费者配置的 groupId 非法,这玩意还有不合法?无非是没指定 groupId 吧? —— 当然不是,如果是因为没有写 groupId 而引起这个问题,那根本不值得去写一编日志了。

groupId 当然是指定的,但为什么还是报了这个错误呢。。。其实原因是没有找到的,但有一个可用版本,一个不可用版本,于是猜测其中可能的原因?

 

2、问题背景

springboot: 1.5.7.RELEASE (有够老的对不对,老项目,没办法。。。这也是这个项目让人头疼的原因)

springcloud: Dalston.SR3

spring-kafka: springboot 指定版本, 好像是 1.1.6.RELEASE

 

3、逐渐找原因

这个是项目上出现的问题,在整合springboot + kafka 之前,我做过另外一个demo, 好用得很。但放到项目上的时候,就出现了水土不服的各种情况就出现了,真的超级多问题,以至于我觉得kafka就是一个坑,为什么还会有人用kafka,其它MQ产品,它不香吗,也不用依赖ZK,用kafka,图什么。。害。(会有这样的疑惑,并且没办法解决,也是因为我对kafka和其它的MQ产品没有一个比较好的横向比较)

说回正题

为什么一个好一个不行呢,差别在哪里,差别就在于一个是 springboot 2.3.5.RELEASE, 一个是 springboot 1.x 。 这可能就是区别!

真是一个让人极度无语的“事故”, 多少问题源于版本不匹配,各种搞来搞去,真的是烦死人。

好了,那既然知道是版本引起的差异,就在 demo 上把版本降下来吧,好嘛,问题果然出现了——版本不兼容,写法可能也不同。

 

4、写法不同,那就改写法

网上查了一下, springboot 1.x 整合kafka 的写法,嗯,果然不一样

springboot 1.x 是需要写 kafkaProducerConfig 和 kafkaConsumerConfig 的。它能够读取到配置,但不知道为啥还报这个错(可能得跟一下代码才行,虽然现在并没有这样的心情)。

OK, 那就按他的写法来写了。发现,竟然可以了,淦。

 

5、剩余的问题

问题还没有被完全解决,一个是配置都写在代码上了,所以,肯定还得写一个配置项,去读取配置才行。

KafkaConfig 读取配置,这样应该就差不多了

然后,纯配置文件的写法,为什么没读取到。这个问题,还得找找,跟一下源码才行

 

这个问题先这样子。

 

标签:springboot,configured,invalid,kafka,问题,版本,写法,groupId
来源: https://www.cnblogs.com/aaacarrot/p/15927430.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有