Re: FlinkKafkaProducer011 fails when kafka broker crash
Yes, this is an expected behavior, flink kafka producer has to
maintain a consistent view of all available partitions(with its
leaders) to align with checkpointing mechanism. In such situation
the expected behavior is to fail the job, restart from checkpoint
and continue processing with newly discovered leaders.
On 04/12/2018 07:06, hzyuemeng1 wrote:
it's normal situation for flink,but maybe kafka