SpringBoot集成Kafka版本不兼容导致出现错误

这篇具有很好参考价值的文章主要介绍了SpringBoot集成Kafka版本不兼容导致出现错误。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

1、系统报错

[kafka-producer-network-thread | producer-1] [] [] ERROR org.apache.kafka.clients.producer.internals.Sender - [Producer clientId=producer-1] Aborting producer batches due to fatal error
org.apache.kafka.common.KafkaException: Unexpected error in InitProducerIdResponse; The server experienced an unexpected error when processing the request.
	at org.apache.kafka.clients.producer.internals.TransactionManager$InitProducerIdHandler.handleResponse(TransactionManager.java:1390)
	at org.apache.kafka.clients.producer.internals.TransactionManager$TxnRequestHandler.onComplete(TransactionManager.java:1294)
	at org.apache.kafka.clients.ClientResponse.onComplete(ClientResponse.java:109)
	at org.apache.kafka.clients.NetworkClient.completeResponses(NetworkClient.java:574)
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:566)
	at org.apache.kafka.clients.producer.internals.Sender.maybeSendAndPollTransactionalRequest(Sender.java:418)
	at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:316)
	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:243)
	at java.lang.Thread.run(Thread.java:748)
[kafka-producer-network-thread | producer-1] [] [] ERROR o.s.kafka.support.LoggingProducerListener - Exception thrown when sending a message with key='null' and 

2、排查与解决
出错原因:springboot集成spring-kafka的时候需要注意两者之间的版本对应关系,因为版本不兼容导致出现错误
解决:kafka-clients : 是springboot集成的spring-kafka,spring-kafka中引入了kafka-client的版本

参考:https://spring.io/projects/spring-kafka
参考:https://stackoverflow.com/questions/72402831/kafka-aborting-producer-batches-due-to-fatal-error文章来源地址https://www.toymoban.com/news/detail-626739.html

到了这里,关于SpringBoot集成Kafka版本不兼容导致出现错误的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Windows系统缺失snmpapi.dll文件导致出现错误解决办法

    其实很多用户玩单机游戏或者安装软件的时候就出现过这种问题,如果是新手第一时间会认为是软件或游戏出错了,其实并不是这样,其主要原因就是你电脑系统的该dll文件丢失了或没有安装一些系统软件平台所需要的动态链接库,这时你可以下载这个snmpapi.dll文件(挑选合适

    2024年02月22日
    浏览(61)
  • 实战:Spring Cloud Stream集成兼容多消息中间件kafka、rabbitmq

    前面的博文我们介绍并实战演示了Spring Cloud Stream整合rabbitmq,其中主要介绍了如何使用和配置完成消息中间件的集成。但是,在实际的生产环境中可能会用到多个消息中间件,又或者是由于业务改变需要更换消息中间件,在这些情况下我们的Spring Cloud Stream框架可以完全兼容多

    2024年02月08日
    浏览(50)
  • 系统缺失mscomm32.ocx文件导致程序出现错误怎么办?

    其实很多用户玩单机游戏或者安装软件的时候就出现过这种问题,如果是新手第一时间会认为是软件或游戏出错了,其实并不是这样,其主要原因就是你电脑系统的该dll文件丢失了或没有安装一些系统软件平台所需要的动态链接库,这时你可以下载这个mscomm32.ocx文件(挑选合适

    2024年02月13日
    浏览(50)
  • 外星人控制中心(AWCC)出现错误日志导致电脑卡顿的解决建议

    我的设备是一台19年的戴尔G3 3590,在更新了最新的AWCC之后电脑出现随机卡顿,于是开始尝试解决问题,最后在戴尔支持技术人员的帮助下解决了卡顿问题,AWCC正常工作,G模式也能正常开启。以下是一些解决建议。 按照戴尔支持技术人员的说法,戴尔针对新版本的AWCC导致电

    2024年02月11日
    浏览(224)
  • spring-kafka之请求响应模式

            kafka是一款性能强劲的分布式流式处理软件,被广泛用于大数据应用场景。所以很多小伙伴对kafka肯定不会陌生,但是kafka的请求响应模式估计使用的却不一定很多。首先简单唠叨下什么是请求响应模式,这个类似于http请求一样发出请求能够在一个请求中返回结果

    2024年02月11日
    浏览(41)
  • 高版本SpringBoot兼容低版本ElasticSearch解决方案

    由于公司最近需要接入日志数据,然而日志数据在ElasticSearch(版本为 6.8.23)里面,但是接入数据项目使用的是Spring Boot 2.4.x版本,根据Spring Data官方提供的版本对应,明显对应不上,官方文档地址:Spring Data Elasticsearch - Reference Documentation Spring Data Release Train Spring Data Elasticse

    2024年02月07日
    浏览(39)
  • Spring-Kafka生产者源码分析

    本文主要概括Spring Kafka生产者发送消息的主流程 代码准备: SpringBoot项目中maven填加以下依赖 消息发送使用 KafkaTemplate 启动类 KafkaAutoConfiguration 有两个地方需要关注 其中的 ProducerFactory 使用的是 DefaultKafkaProducerFactory 在发送消息之前,Spring Kafka会先创建 Producer ,返回的是 Clos

    2024年02月09日
    浏览(38)
  • SpringBoot和JDK版本兼容性

    SpringBoot和JDK版本兼容问题,就是SpringBoot的每个版本支持哪些JDK版本。 在spring官网、spring-boot项目的github地址都没有找到一个统一的总结,类似表格这样,所以到spring-boot的各个版本的文档中找出来。如果有官方的总结我没找到的,可以跟我说下。 下面的表格列出了SpringBoot版

    2024年02月01日
    浏览(49)
  • Maven项目打包,出现提示 Lombok 版本和 jdk 的编译器不兼容问题,解决办法。

    class lombok.javac.apt.LombokProcessor (in unnamed module @0x7d21852b) cannot access class com.sun.tools.javac.processing.JavacProcessingEnvironment (in module jdk.compiler) because module jdk.compiler does not export com.sun.tools.javac.processing to unnamed module @0x7d21852b 这些引用都是关于Java编译器插件Lombok的错误信息。Lombok是一个

    2024年02月05日
    浏览(49)
  • Jenkins上跑自动化项目,case出现错误时,导致项目运行时间过长,该如何处理?

    进入配置: 构建环境: 自行选择超时时间即可~ 安装插件:pytest-timeout 选择一:装饰器用法:将单个测试用例标记为超时: 选择二:存放到pytest.ini,直接执行pytest:

    2024年01月25日
    浏览(56)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包