How to pass application name when using FlinkKinesisConsumer

[Xixi Li]

Hi

I have a question about how we can set up a kinesis consumer with a
specified applicationName, we are currently using flink-connector-kinesis
version 1.5, but we cant find any where to set up the applicationName. Thank
you very much!

Regards,
Xixi



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Biao Liu]

Hi Xixi,

I'm not sure I have understood correctly, do you mean you would like to set the "kinesis consumer" name?

Does the API "StreamExecutionEnvironment.addSource($KinesisConsumer, $sourceName)" satisfy this?

Xixi Li <[hidden email]> 于2019年4月23日周二 上午3:25写道：

Hi

I have a question about how we can set up a kinesis consumer with a
specified applicationName, we are currently using flink-connector-kinesis
version 1.5, but we cant find any where to set up the applicationName. Thank
you very much!

Regards,
Xixi



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Xixi Li]

Hey Liu,

Thank you for your response, by saying applicationName, i meant the name to
control table in Amazon DynamoDB while creating a consumer. Usually in the
non-flink env, we are able to control it by passing the applicationName in
the configuration properties when creating a Worker using kinesis client
library. But we didn't find such option when using FlinkKinesisConsumer.

Regards,
Xixi



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/