Robert Metzger created FLINK-4191: ------------------------------------- Summary: Expose shard information in KinesisDeserializationSchema Key: FLINK-4191 URL: https://issues.apache.org/jira/browse/FLINK-4191 Project: Flink Issue Type: Sub-task Components: Kinesis Connector, Streaming Connectors Affects Versions: 1.1.0 Reporter: Robert Metzger Assignee: Robert Metzger Fix For: 1.1.0
Currently, we are not exposing the Shard ID and other shard-related information in the deserialization schema. -- This message was sent by Atlassian JIRA (v6.3.4#6332)