FlinkFlink Starting Offset 启动消费位置 指定时间消费
Posted 九师兄
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了FlinkFlink Starting Offset 启动消费位置 指定时间消费相关的知识，希望对你有一定的参考价值。
文章目录
1.概述
首先参考文章：【Flink】Flink 1.14.0 全新的 Kafka Connector
Kafka Source 能够通过指定 OffsetsInitializer来消费从不同偏移量开始的消息。内置的初始值设定项包括：
KafkaSource.builder()
// Start from committed offset of the consuming group, without reset strategy
.setStartingOffsets以上是关于FlinkFlink Starting Offset 启动消费位置 指定时间消费的主要内容，如果未能解决你的问题，请参考以下文章