[
https://issues.apache.org/jira/browse/FLINK-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321674#comment-17321674
]
Flink Jira Bot commented on FLINK-5953:
---------------------------------------
This issue and all of its Sub-Tasks have not been updated for 180 days. So, it
has been labeled "stale-minor". If you are still affected by this bug or are
still interested in this issue, please give an update and remove the label. In
7 days the issue will be closed automatically.
> Sample Kinesis Scala code doesn't work
> --------------------------------------
>
> Key: FLINK-5953
> URL: https://issues.apache.org/jira/browse/FLINK-5953
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kinesis, Documentation
> Affects Versions: 1.2.0
> Reporter: Matthew Billson
> Priority: Minor
> Labels: documentation, kinesis, scala, stale-minor
> Original Estimate: 1h
> Remaining Estimate: 1h
>
> In the Scala Kinesis example here:
> https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/connectors/kinesis.html
> we see the following:
> {code}val consumerConfig = new Properties();
> consumerConfig.put(ConsumerConfigConstants.AWS_REGION, "us-east-1");
> consumerConfig.put(ConsumerConfigConstants.AWS_ACCESS_KEY_ID,
> "aws_access_key_id");
> consumerConfig.put(ConsumerConfigConstants.AWS_SECRET_ACCESS_KEY,
> "aws_secret_access_key");
> consumerConfig.put(ConsumerConfigConstants.STREAM_INITIAL_POSITION,
> "LATEST");{code}
> but in Scala ConsumerConfigConstants does not inherit the static members of
> AWSConfigConstants and so only the 4th line of this actually works.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
