Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-5953

Sample Kinesis Scala code doesn't work

    XMLWordPrintableJSON

Details

    Description

      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: 

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

      but in Scala ConsumerConfigConstants does not inherit the static members of AWSConfigConstants and so only the 4th line of this actually works.

      Attachments

        Activity

          People

            dannycranmer Danny Cranmer
            mbillson Matthew Billson
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Time Tracking

                Estimated:
                Original Estimate - 1h
                1h
                Remaining:
                Remaining Estimate - 1h
                1h
                Logged:
                Time Spent - Not Specified
                Not Specified