我想问一下我在写spark实时项目时候,出现获取offset都是0,这是怎么回事?
kafka+redis,用redis记录offset的值,但是取出来都是0.。
解决啦 我糊涂忘记让kafka继续分流操作了 取完offset后以为万事大吉了,检查了两个小时才分现
保存offset值到Redis中的时候没有正确的更新,每次读取offset的值都是0。检查Redis中是否保存了offset值,并且在每次读取offset值之前判断是否存在,如果不存在,则从Kafka中获取最新的offset值并保存到Redis中。