Details
-
Bug
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
2.0.0
-
None
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.
Attachments
Issue Links
- links to