kafka生成者发送消息失败报错:RecordTooLargeException

server/2025/3/18 19:26:02/

 

kafka生成者发送消息典型案例

生产者 发送消息失败:Failed to send; nested exception is org.apache.kafka.common.errors.RecordTooLargeException: The message is 1053512 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.

原因:序列化时,消息为1053512字节,大于您使用max.request.size配置配置的最大请求大小。

 

kafka默认生成者发送消息的大小为:1048576 即为1M,当发送的消息大于1M的时候就会拒绝发送,导致生产者发送消息失败。

分析:

当在yml里面配置kafka打印详情日志发现,默认的大小的确为:1048576 即为1M

logging:level.org.apache.kafka: DEBUG

所以就要在yml里面配置大于1M的配置属性

spring:kafka:producer:properties:# 根据需求调整(例如设为 2MB) 2MB = 2 * 1024 * 1024max.request.size: 2097152

重启服务,即可发现日志有打印发送成功:生产者 发送消息成功:SendResult

kafka消费端对应也需要配置下,不然也会发送失败,在kafka配置文件config/server.properties下,新增配置如下:

message.max.bytes=2097152
replica.fetch.max.bytes=2097152

记得重启kafka服务


http://www.ppmy.cn/server/176031.html

相关文章

uniapp vue3项目定义全局变量,切换底部babar时根据条件刷新页面

前言 uniapp项目中,每个tabbar页面来回点时候,不会触发页面更新。但是有时页面上有数据发生改变需要更新模版时,就得能及时的通知到页面。如果在onshow生命周期里每次都调用异步请求更新数据,有些不合理,况且页面有时…

界面组件DevExpress WPF中文教程:Grid - 如何显示嵌套栏(Bands)?

DevExpress WPF拥有120个控件和库,将帮助您交付满足甚至超出企业需求的高性能业务应用程序。通过DevExpress WPF能创建有着强大互动功能的XAML基础应用程序,这些应用程序专注于当代客户的需求和构建未来新一代支持触摸的解决方案。 无论是Office办公软件…

SEO优先级矩阵:有限资源下的ROI最大化决策模型

SEO优先级矩阵:有限资源下的ROI最大化决策模型 引言 在数字营销领域,搜索引擎优化(SEO)是提升网站流量和转化率的关键策略之一。然而,SEO的实施往往需要投入大量的时间和资源,尤其是在资源有限的情况下&a…

DeepSeek:从入门到精通

DeepSeek是什么? DeepSeek是一家专注通用人工智能(AGI)的中国科技公司,主攻大模型研发与应 用。DeepSeek-R1是其开源的推理模型,擅长处理复杂任务且可免费商用。 Deepseek可以做什么? 直接面向用户或者支持…

logparser日志分析详解

无问社区-官网:http://www.wwlib.cn 本期无人投稿,欢迎大家投稿,投稿可获得无问社区AI大模型的使用红包哦! 无问社区:网安文章沉浸式免费看! 无问AI大模型不懂的问题随意问! 全网网安资源智…

VLLM专题(二十六)—使用 Docker

使用 vLLM 的官方 Docker 镜像 vLLM 提供了一个官方 Docker 镜像用于部署。该镜像可用于运行与 OpenAI 兼容的服务器,并可在 Docker Hub 上获取,名称为 vllm/vllm-openai。 docker run --runtime nvidia --gpus all \-v ~/.cache/huggingface:/root/.cache/huggingface \--…

Bash中关于制表符\t站位情况说明

1、首先制表符\t占多少个空格并不是固定不变的。 2、不同系统会以4个或8个空格为基本长度,记为tabL,则实际的缩进长度: length |n - tabL| % tabL 计算机会把制表符/t前的字符串转化成每tabL一组,其中n表示制表符/t最前面一组字符长度。 …

【Unity网络同步框架 - Nakama研究(二)】

Unity网络同步框架 - Nakama研究(二) 虽说官方文档和网站以及论坛建立的不错,而且还有中文翻译且质量也不错,但是总会遇到一些词不达意,说了但是依旧没懂的部分,甚至问AI也问不出什么东西,所以需要有一些比较明显的博客…