[BEAM-2581] KinesisClientProvider interface needs to be public

• Type: Bug
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Affects Version/s: 2.0.0
• Fix Version/s: 2.2.0
• Component/s: io-java-kinesis
• Assignee: Chamikara Madhusanka Jayalath
• Reporter: Nawaid Shamim
• Created: 11/Jul/17 14:00
• Updated: 16/May/20 13:19
• Resolved: 07/Sep/17 02:40

Description

Using Beam to read from kinesis stream. KinesisIO provides two overloaded methods - withClientProvider to provide AWS credentials or implement an interface - KinesisClientProvider to pass AWSKinesisClient as described on here

There's also possibility to start reading using arbitrary point in time - in this case you need to provide Instant object:
 p.apply(KinesisIO.read()
     .from("streamName", instant)
     .withClientProvider(new KinesisClientProvider() {
                        @Override
                        public AmazonKinesis get() {
                            return null;
                        }
      })
  .apply( ... ) // other transformations

The above code requires org.apache.beam.sdk.io.kinesis.KinesisClientProvider interface to be public.

Issue Links

• links to: GitHub Pull Request #3540