FAQ - kafka 任务报错读到了不存在的偏移量

问题描述/异常栈
kafka 任务报错读到了不存在的偏移量
FAQ - kafka 任务报错读到了不存在的偏移量 - 图1
发现版本
flink 114
解决方案
配置auto-offset-reset 示例
CREATE TABLE your_table_name (
) WITH (
'connector' = 'kafka',
'topic' = 'your_topic_name',
'properties.bootstrap.servers' = 'your_bootstrap_servers',
'properties.group.id' = 'your_group_id',
'properties.auto.offset.reset' = 'earliest' );
示例中，通过设置properties.auto.offset.reset属性为earliest，来设置消费者组在找不到先前偏移量时从最早的可用消息开始消费。
问题原因
待补充

作者：林帅