我这个flink作业和和分组都是新创建的,没有抽取历史
group是新的

魏子涵 <wzh1007181...@163.com> 于2020年8月14日周五 下午1:20写道:

> Kafka客户端的group. id参数有改吗?
>
>
> | |
> 魏子涵
> |
> |
> 邮箱:wzh1007181...@163.com
> |
>
> 签名由 网易邮箱大师 定制
>
> 在2020年08月14日 12:44,yulu yang 写道:
> 在flink作业中从kafka数据源获取数据,将 参数设置为'scan.startup.mode' = 'earliest-offset',
> 检测flink运行结果时,发现只抽取了kafka中的newest数据,没有获取到oldest数据。
> 不知道是不是我这里'scan.startup.mode' 参数用的不对。
> Flink 版本1.11.1 kafka版本 2.6.0
>

回复