[
https://issues.apache.org/jira/browse/FLINK-8118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16264140#comment-16264140
]
ASF GitHub Bot commented on FLINK-8118:
---------------------------------------
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5056#discussion_r152763593
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -309,6 +356,51 @@ public B withKafkaTimestampAsRowtimeAttribute(
return builder();
}
+ /**
+ * Configures the TableSource to start reading from the
earliest offset for all partitions.
+ *
+ * @see FlinkKafkaConsumerBase#setStartFromEarliest()
+ */
+ public B startReadingFromEarliest() {
+ this.startupMode = StartupMode.EARLIEST;
+ this.specificStartupOffsets = null;
+ return builder();
+ }
+
+ /**
+ * Configures the TableSource to start reading from the latest
offset for all partitions.
+ *
+ * @see FlinkKafkaConsumerBase#setStartFromLatest()
+ */
+ public B startReadingFromLatest() {
--- End diff --
shorten to `fromLatestOffsets`?
> Allow to specify the offsets of KafkaTableSources
> -------------------------------------------------
>
> Key: FLINK-8118
> URL: https://issues.apache.org/jira/browse/FLINK-8118
> Project: Flink
> Issue Type: New Feature
> Components: Table API & SQL
> Affects Versions: 1.4.0
> Reporter: Timo Walther
> Assignee: Xingcan Cui
>
> Right now the Kafka TableSources can only read from the current group offset.
> We should expose the possibilities of the Kafka Consumer:
> https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/connectors/kafka.html#kafka-consumers-start-position-configuration
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
