[
https://issues.apache.org/jira/browse/FLINK-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-5953:
----------------------------------
Component/s: Connectors / Kinesis
> 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
> 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)
