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

            • Assignee:
              Unassigned
              Reporter:
              mbillson Matthew Billson
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated:

                Time Tracking

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