[
https://issues.apache.org/jira/browse/FLINK-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-5953:
-----------------------------------
Fix Version/s: 1.15.0
> 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
> Assignee: Danny Cranmer
> Priority: Not a Priority
> Labels: documentation, kinesis, scala
> Fix For: 1.15.0
>
> 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.20.10#820010)
