[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948458#comment-15948458
]
ASF GitHub Bot commented on FLINK-5625:
---------------------------------------
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3651#discussion_r108845204
--- Diff: docs/dev/connectors/kinesis.md ---
@@ -121,9 +121,11 @@ one of the following values in the provided
configuration properties (the naming
- `LATEST`: read all shards of all streams starting from the latest record.
- `TRIM_HORIZON`: read all shards of all streams starting from the
earliest record possible (data may be trimmed by Kinesis depending on the
retention settings).
- `AT_TIMESTAMP`: read all shards of all streams starting from a specified
timestamp. The timestamp must also be specified in the configuration
-properties by providing a value for
`ConsumerConfigConstants.STREAM_INITIAL_TIMESTAMP`, either in the date pattern
-`yyyy-MM-dd'T'HH:mm:ss.SSSXXX` (for example,
`2016-04-04T19:58:46.480-00:00`), or a non-negative double value representing
the number of seconds
-that has elapsed since the Unix epoch (for example, `1459799926.480`).
+properties by providing a value for
`ConsumerConfigConstants.STREAM_INITIAL_TIMESTAMP`, in one of the following
date pattern :
+ - `yyyy-MM-dd'T'HH:mm:ss.SSSXXX` (for example,
`2016-04-04T19:58:46.480-00:00`).
--- End diff --
Also, do you think it would make sense to have a simpler default format?
> Let Date format for timestamp-based start position in Kinesis consumer be
> configurable.
> ---------------------------------------------------------------------------------------
>
> Key: FLINK-5625
> URL: https://issues.apache.org/jira/browse/FLINK-5625
> Project: Flink
> Issue Type: Improvement
> Components: Kinesis Connector
> Reporter: Tzu-Li (Gordon) Tai
> Assignee: Wei-Che Wei
>
> Currently, the Kinesis consumer's Date format for timestamp-based start
> positions is fixed. It'll be nice to make this format configurable.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
