I'm adding Danny to this thread. He might be able to help on this topic.
Best,
Matthias
On Mon, Jan 3, 2022 at 4:57 PM Daniel Vol wrote:
> I definitely do, and you can see in my initial post that this is the first
> thing I tried but I got warnings and it doesn't use credentials I supplied.
> T
I definitely do, and you can see in my initial post that this is the first
thing I tried but I got warnings and it doesn't use credentials I supplied.
Though you are right that I do find a solution - using credentialProvider
object and injecting keys as a java env variables through:
-yd "env.java.o
Hi Daniel,
I'm assuming you already looked into the Flink documentation for this topic
[1]? I'm gonna add Fabian to this thread. Maybe, he's able to help out here.
Matthias
[1]
https://nightlies.apache.org/flink/flink-docs-release-1.12/dev/connectors/kinesis.html#kinesis-producer
On Fri, Dec 31,
Hi,
I am trying to run a Flink on GCP with the current source and
destination on Kinesis on AWS.
I have configured the access key on AWS to be able to connect.
I am running Flink 1.12.1
In flink I use the following code (Scala 2.12.2)
val props = new Properties
props.put(AWSConfigConstants.AWS_A
