Re: FlinkKafkaConsumer and FlinkKafkaProducer and Kafka Cluster Migration

2022-01-17 Thread Martijn Visser
> *From:* Fabian Paul > *Sent:* Friday, January 14, 2022 4:02 AM > *To:* Alexey Trenikhun > *Cc:* Flink User Mail List > *Subject:* Re: FlinkKafkaConsumer and FlinkKafkaProducer and Kafka > Cluster Migration > > Hi Alexey, > > The bootstrap servers are not

Re: FlinkKafkaConsumer and FlinkKafkaProducer and Kafka Cluster Migration

2022-01-17 Thread Alexey Trenikhun
s.apache.org From: Fabian Paul Sent: Friday, January 14, 2022 4:02 AM To: Alexey Trenikhun Cc: Flink User Mail List Subject: Re: FlinkKafkaConsumer and FlinkKafkaProducer and Kafka Cluster Migration Hi Alexey, The bootstrap servers are not part of the state so

Re: FlinkKafkaConsumer and FlinkKafkaProducer and Kafka Cluster Migration

2022-01-14 Thread Fabian Paul
Hi Alexey, The bootstrap servers are not part of the state so you are good to go although please stop all your jobs with a savepoint and resume from it with the new properties. I guess to migrate the FlinkKafkaConsumer to an empty topic you can discard the state if you ensure that all messages beg

FlinkKafkaConsumer and FlinkKafkaProducer and Kafka Cluster Migration

2022-01-13 Thread Alexey Trenikhun
Hello, Currently we are using FlinkKafkaConsumer and FlinkKafkaProducer and planning to migrate to different Kafka cluster. Are boostrap servers, username and passwords part of FlinkKafkaConsumer and FlinkKafkaProducer ? So if we take savepoint change boostrap server and credentials and start