Re: Change Kafka cluster without loosing the Flink's state

Posted by kla on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Change-Kafka-cluster-without-loosing-the-Flink-s-state-tp15572p15588.html

Hi Gordon,

Thanks for your quick reply.

I have following consumer:

jobConfiguration.getEnv().addSource(
new FlinkKafkaConsumer010<>(properties.getProperty(TOPIC), deserializer,
properties));

How can I set the UID for the consumer ?

Thanks again for help!

Regards,
Konstantin



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