[
https://issues.apache.org/jira/browse/FLINK-8118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262563#comment-16262563
]
Xingcan Cui commented on FLINK-8118:
------------------------------------
Hi [~fhueske], thanks for the suggestions!
Since the existing configurations in {{KafkaTableSource.Builder}} are all about
the {{TableSource}} itself while the starting offsets are set for the inner
{{FlinkKafkaConsumerBase}}, the code may be a little verbose. Anyway, I'll
create a PR soon and let's discuss that later.
Thanks, Xingcan
> 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)
