kafka里面当前消息2942497,invalid是false
项目中报错
并且会一直循环输出这个错误
之前有用过配置kafka跳过此消息，但是每次都要手动去修改，有没有办法在报错后，跳过此消息
kafka消息损坏，消费者一直循环消费
项目中报错
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
1条回答 默认 最新
日落西风又在吹 2022-01-11 12:42关注kafka没有重试机制不支持消息重试，也没有死信队列，因此使用kafka做消息队列时，如果遇到了消息在业务处理时出现异常，就会很难进行下一步处理。应对这种场景，需要自己实现消息重试的功能。
捕获异常消息，自行处理
解决 无用评论 打赏举报 分享
- 2022-08-23 10:01回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
- 2022-12-21 00:45回答 1 已采纳 这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
- 2022-10-25 09:26回答 5 已采纳 感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
- 2021-02-09 14:05玉&心的博客 用于实现org.apache.kafka.common.serialization.Deserializer接口的键的反序列化器类。 2.value.deserializer 用于实现org.apache.kafka.common.serialization.Deserializer接口的值的反序列化器类。 3.bootstrap...
- 2021-07-05 16:53回答 1 已采纳 value的值为[B@1e1e585b这个明显是序列化后的Bytes字节类型嘛你反序列化成string就ok了
- 2022-06-11 10:41回答 1 已采纳 给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
- 2021-07-02 11:07回答 2 已采纳 对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说， 你只需要消费下一条就行了。至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地
- 2024-05-29 00:52AI天才研究院的博客 KafkaOffset重置：调整消费进度 1.背景介绍 1.1 Apache Kafka简介 Apache Kafka是一个分布式流处理平台,它提供了一种统一、高吞吐、低延迟的方式来处理实时数据流。Kafka被广泛应用于
- 2022-01-10 15:46回答 3 已采纳 消费者和生产者与机器无关，这是不同的概念，消费者与生产者只是在Kafka中的角色，不同角色干不同的事情
- 2018-04-27 17:31回答 2 已采纳 1, 先确认你的网络有没有问题 2，在向服务器发起连接后，在kafka的服务器配置中有zookeeper.connect=xx.xx.xx.xx：2181的配置 这时候kafka会查找zookeep
- 2021-12-12 10:23回答 1 已采纳 写库的性能取决于DB的配置，IO性能、磁盘的配置以及数据结构的设计（比如索引不要设计太多，表结构尽量简单化）等等， 单纯从逻辑层面优化，办法比较少，要么是换成Nosql数据库，要么是增加数据库的实例来
- 2024-06-12 09:00夏之以寒的博客 Kafka作为一款高性能的分布式消息队列系统，在处理消费者故障和活锁问题时表现出了卓越的性能和稳定性。通过消费者组、偏移量提交、自动重平衡等机制以及优化消息处理逻辑、设置合理的超时时间、引入优先级机制和...
- 2022-01-28 09:47回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
- 2021-07-12 20:18顧棟的博客 文章目录Kafka生产者默认配置Kafka消费者默认配置 Kafka生产者默认配置 参数名 默认值 参数说明 retries 0 设置大于零的值将导致客户端重新发送任何发送失败并可能出现暂时性错误的记录。 acks 1 在认为...
- 2021-07-24 11:16m0_57286679的博客 31、qmq消息的实现机制(qmq是去哪儿网自己封装的消息队列) 32、遍历hashmap的三种方式 33、JVM的一些命令 34、memcache和redis的区别 35、Mysql的行级锁加在哪个位置 36、ConcurrentHashmap的锁是如何加的？...
- 没有解决我的问题, 去提问
问题事件
创建了问题
1月11日
悬赏问题
- ¥15 鼠标右键，撤销删除 复制 移动，要怎样删除
- ¥15 使用MATLAB进行余弦相似度计算加速
- ¥15 服务器安装php5.6版本
- ¥15 我想用51单片机和数码管做一个从0开始的计数表 我写了一串代码 但是放到单片机里面数码管只闪烁一下然后熄灭
- ¥20 系统工程中，状态空间模型中状态方程的应用。请猛男来完整讲一下下面所有问题
- ¥15 我想在WPF的Model Code中获取ViewModel Code中的一个参数
- ¥15 arcgis处理土地利用道路 建筑 林地分类
- ¥20 使用visual studio 工具用C++语音，调用openslsx库读取excel文件的sheet问题
- ¥100 寻会做云闪付tn转h5支付链接的技术
- ¥15 DockerSwarm跨节点无法访问问题