Added community as well for below query. From: Kamal Mittal Sent: 22 July 2025 07:40 To: Hongshun Wang <loserwang1...@gmail.com> Subject: RE: Kafka cluster rebalancing
So in Apache Flink based kafka source/sink, autoscaling followed by rebalancing can’t be supported? From: Hongshun Wang <loserwang1...@gmail.com<mailto:loserwang1...@gmail.com>> Sent: 22 July 2025 07:38 To: Kamal Mittal <kamal.mit...@ericsson.com<mailto:kamal.mit...@ericsson.com>> Subject: Re: Kafka cluster rebalancing NO, if rebalancing, the offset of kafka split is not right, which will causing data incorrect. On Mon, Jul 21, 2025 at 6:00 PM Kamal Mittal via user <user@flink.apache.org<mailto:user@flink.apache.org>> wrote: Hello, Planning to use Cruise control for kafka cluster rebalancing due to scaling etc. and using Flink kakfa source/sink. Query is that if there are pauses during rebalancing w.r.t producer/consumer using topic partitions for data read/write then will the flink connectors for kafka brokers may fail or disconnect? Rgds, Kamal