[
https://issues.apache.org/jira/browse/FLINK-8118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16264305#comment-16264305
]
ASF GitHub Bot commented on FLINK-8118:
---------------------------------------
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5056#discussion_r152795641
--- Diff: docs/dev/table/sourceSinks.md ---
@@ -264,6 +288,30 @@ val source: TableSource[_] =
Kafka010AvroTableSource.builder()
</div>
</div>
+* **Specify the start reading position:** By default, the table source
will start reading data from the committed group offsets in Zookeeper or Kafka
brokers. You can specify other start positions via the builder's methods, which
correspond to the configurations in section [Kafka Consumers Start Position
Configuration](../connectors/kafka.html#kafka-consumers-start-position-configuration).
+
+<div class="codetabs" markdown="1">
+<div data-lang="java" markdown="1">
+{% highlight java %}
+TableSource source = Kafka010JsonTableSource.builder()
--- End diff --
This should be Kafka010AvroTableSource.
> 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)
