[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948607#comment-15948607
]
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_r108861953
--- Diff: docs/dev/connectors/kinesis.md ---
@@ -122,10 +122,10 @@ one of the following values in the provided
configuration properties (the naming
- `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`, 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`).
- a non-negative double value representing the number of seconds that
has elapsed since the Unix epoch (for example, `1459799926.480`).
- - a user defined pattern, which is a valid pattern for
`SimpleDateFormat` provided by
`ConsumerConfigConstants.STREAM_TIMESTAMP_DATE_FORMAT`,
- (for example, timestamp value is `2016-04-04` and pattern is
`yyyy-MM-dd` given by user).
+ - a user defined pattern, which is a valid pattern for
`SimpleDateFormat` provided by
`ConsumerConfigConstants.STREAM_TIMESTAMP_DATE_FORMAT`.
+ If `ConsumerConfigConstants.STREAM_TIMESTAMP_DATE_FORMAT` is not
defined then ehe default pattern will be `yyyy-MM-dd'T'HH:mm:ss.SSSXXX`
--- End diff --
type: "ehe"
> 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)
