[jira] [Resolved] (FLINK-5953) Sample Kinesis Scala code doesn't work

["Danny Cranmer (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Danny Cranmer resolved FLINK-5953.
----------------------------------
      Assignee: Danny Cranmer
    Resolution: Fixed

> 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
>   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)