ERROR 220624 --- [ntainer#2-2-C-1] o.s.k.l.KafkaMessageListenerContainer : Failed to set initial

完整报错：

org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition heartbeatMessage1-2 could be determined2021-12-03 16:17:44.253 ERROR 220624 --- [ntainer#2-1-C-1] o.s.k.l.KafkaMessageListenerContainer    : Failed to set initial offsetsorg.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition heartbeatMessage1-1 could be determined

我的感觉应该是分区有问题，比如只创建了一个分区，我却消费第2个分区，但是我在kafka-eagele或者kafkaTool上看都是3个分区，后面还是在kafkaEagle上面突然看到了有的是1个分区的Topic，而这是不可能的，因为我的Topic都是自己手建的，没有默认创建。

后来发现是一字之差

@Beanpublic NewTopic initialBHeartBeatMessageTopic() {return new NewTopic("heartBeatMessage",3, (short) 3);}

我创建的是heartBeatMessage，而消费的却是

@KafkaListener(groupId = "message", topicPartitions = {@TopicPartition(topic = "heartbeatMessage",partitions = {"0", "1","2"})},concurrency = "3")//concurrency就是同组下的消费者个数，就是并发消费数，建议小于等于分区总数

因为kafka没有heartbeartMessage的主题，所以会默认自己创建1个分区1个副本的主题，这样在消费的时候就会出现问题了。

关于如何关闭这个可恶的自动创建Topic功能，毕竟如果没有联想到Topic使用错误的原因，想找到这个bug还是很痛苦的，网上的说法是在kafka的server.properties中加上这句话

auto.create.topics.enable=false

不过我在配置文件中并没有找到这个配置的说明，也没有去尝试，老铁们如果有这个苦恼可以加上试试，当然别忘了所有broker的配置都要改，然后重启kafka。

有疑问可以在评论区交流，作者看见会回复。

如需转载，请一定声明原处。

ERROR 220624 --- [ntainer#2-2-C-1] o.s.k.l.KafkaMessageListenerContainer : Failed to set initial相关推荐

ERROR o.s.a.r.l.SimpleMessageListenerContainer : Failed to check/redeclare auto-delete queue(s).
rabbitmq出现这种问题一般就是你的生产者的交换机的名称,和你在配置监听者配置的交换机的名称不一致引用:https://blog.csdn.net/yy756127197/article/det ...
eclipse链接Hadoop集群时报错Error：Call From xxx/xxx.xxx.xxx.xxx to hostname1:9000 failed on connection excep
今天用eclipse连接Hadoop集群的时候突然给我报了这样一个错误:Error:Call From xxx/xxx.xxx.xxx.xxx to hostname1:9000 failed on ...
error: 'lianxi/' does not have a commit checked out fatal: adding files failed 解决方案
dell@DESKTOP-4JSV58G MINGW64 /d/mytest/lianxi (router-city) $ git add . error: 'lianxi/' does not ha ...
Flutter打包iOS上传 AppStore ERROR ITMS-90432: “Invalid Swift Support. The file Runner.app/Frameworks/.l
在码农的世界里,优美的应用体验,来源于程序员对细节的处理以及自我要求的境界,年轻人也是忙忙碌碌的码农中一员,每天.每周,都会留下一些脚印,就是这些创作的内容,有一种执着,就是不知为什么,如果你迷茫,不 ...
报错笔记-[error] 1615#0: *14 open() “/usr/local/nginx/html/course/zk.jpg“ failed (2: No such file or dir
出现如上错误,有三个方面会引起配置文件有冲突配置的不对 nginx执行未按照该配置文件使用./nginx -t 编译,还是./nginx启动,都是可以的,但是只能访问默认的欢迎页面,即使配置文件 ...
fatal - Error: Register plugin D:/youqu/yuntu-back/node_modules/@umijs/plugins/dist/layout.js failed
记录项目遇到的问题: 合并代码之后,删掉nodemodlues,重新npm install 报错: 找了很多方法,通过重新安装react解决: npm install react 因为报错的地方是,找 ...
SpringBoot集成Kafka消息队列
1.说明 Spring可以方便的集成使用 Kafka消息队列 , 只需要引入依赖包spring-kafka, 注意版本兼容问题, 本文详细介绍SpringBoot集成Kafka的方法, 以及生产者和消 ...
kafka 重复消费场景及解决方案
1.与消费者有关的重要参数在讨论重复消费之前,首先介绍一下kafka中几个跟消费有关的配置参数. enable.auto.commit 默认值true,表示消费者会周期性自动提交消费的offset ...
kafka 运维中遇到的问题
1,java.lang.InternalError: a fault occurred in a recent unsafe memory access operation in compiled k ...

ERROR 220624 --- [ntainer#2-2-C-1] o.s.k.l.KafkaMessageListenerContainer : Failed to set initial

ERROR 220624 --- [ntainer#2-2-C-1] o.s.k.l.KafkaMessageListenerContainer : Failed to set initial相关推荐

最新文章

热门文章