kafka消费reset offset问题

kafka消费端包如下错误：

2016-07-12 14:02:45,076 [ConsumerFetcherThread-order-consumer-group_iZ25mmzglleZ-1468299172455-8b8f5ebd-0-3] ERROR [ConsumerFetcherThread:97] - [ConsumerFetcherThread-order-consumer-group_iZ25mmzglleZ-1468299172455-8b8f5ebd-0-3], Current offset 458416 for partition [order-consumer-group,0] out of range; reset offset to 580644

如何让消费者从 offset 458416 消费。配置auto.offset.reset=smallest 无效。有什么比较好的办法处理？

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除结题
收藏举报

报告相同问题？

关注问题

kafka可以生产无法消费的问题 java kafka
2022-06-11 10:41

回答 1 已采纳给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
kafka消费者创建不了 java kafka linux
2022-08-23 10:01

回答 1 已采纳同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
Springboot集成kafka，应用很卡，消费很慢 java kafka spring boot
2022-10-25 09:26

回答 5 已采纳感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
kafka实战-消费者offset重置问题
2023-02-07 17:29

弋在西元前的博客 kafka消费者offset重置问题
flink消费kafka数据延迟 flink postgresql scala 有问必答
2022-01-28 09:47

回答 1 已采纳那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
关于kafka Debezium捕获mysql问题 java kafka mysql
2022-10-26 12:40

回答 4 已采纳 MySQL binlog状态，连接器startup.model选项使用那种形式，最后不行在看debezium的日志
flink消费kafka flink java kafka 有问必答
2021-07-02 11:07

回答 2 已采纳对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说，你只需要消费下一条就行了。至于偏移量，你第一次消费的时候，是要发送偏移的，这个你消费者要本地
kafka消费者offset相关说明
2021-11-05 19:43

仙道Bob的博客 1.kafka中的offset概念 Last Committed Offset：consumer group 最新一次 commit 的 offset，表示这个 group 已经把 Last Committed Offset 之前的数据都消费成功了。 Current Position：consumer group 当前...
spark structured steaming与kafka集成offset管理方式 kafka spark
2023-01-31 14:43

回答 2 已采纳 Spark Structured Streaming 集成 Kafka 的 offset 管理方式有如下几种：利用 Spark checkpoint 文件提交 offset 给 Kafka常用的方案
有关kafka消费者的问题，描述如下
2016-05-09 11:56

回答 1 已采纳你的这个结构首先要换一下。如果你要去读取group中不同分区中的数据。对于你的consumer端来说，应该是1对1进行读取，也就是说，一个java进程对应一个分区partition。你自己
kafka中的消费拦截器 flink java kafka
2021-07-05 16:53

回答 1 已采纳 value的值为[B@1e1e585b这个明显是序列化后的Bytes字节类型嘛你反序列化成string就ok了
kafka消费指定offset消息
2021-10-29 14:04

Leftmumu的博客 public static void main(String[] args) { Properties props = new Properties(); props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, ""); ... props.put(ConsumerConfig.AUTO_OFFSET_RESET.
kafka怎么获取之前的offset java linux
2020-04-28 14:06

回答 1 已采纳 kafka消费是可以指定offset的，你手动指定一个不就好了？多个生产者同时发送数据，你是要保证按照发送的顺序一一写到数据库中么？这样子的话可以只给当前topic，设置一个分区就行了不知道我
kafka offset java_Kafka消费者重置offset读取数据
2021-03-06 21:18

脑叔的博客 public class KafkaConsumer2 {public static void main(String[] args) {Properties props = new Properties();props.put("bootstrap.servers", "127.0.0.1:9092");props.put("group.id", "one");props.put("enable...
kafka java设置offset_Kafka auto.offset.reset值详解
2021-03-09 00:05

BugFixer的博客昨天在写一个 java 消费kafka数据的实例，明明设置auto.offset.reset为 earliest，但还是不从头开始消费，官网给出的含义太抽象了。earliest: automatically reset the offset to the earliest offset，自动将偏移量...
没有解决我的问题, 去提问

悬赏问题

¥15 素材场景中光线烘焙后灯光失效
¥15 请教一下各位，为什么我这个没有实现模拟点击
¥15 执行 virtuoso 命令后，界面没有，cadence 启动不起来
¥50 comfyui下连接animatediff节点生成视频质量非常差的原因
¥20 有关区间dp的问题求解
¥15 多电路系统共用电源的串扰问题
¥15 slam rangenet++配置
¥15 有没有研究水声通信方面的帮我改俩matlab代码
¥15 ubuntu子系统密码忘记
¥15 保护模式-系统加载-段寄存器

码龄粉丝数原力等级 --

kafka消费reset offset问题

0条回答默认最新

悬赏问题

kafka消费reset offset问题

0条回答 默认 最新

悬赏问题

0条回答默认最新