A partition migration can happen, using stale metadata, when the partition is validating a next_fetch_startand retring the validation.
It can use stale metadata with an invalid leader epoch and migrate back to the previous leader. Later this is corrected but it's sub-optimal.
How to reproduce
Execute test 0146/do_test_stale_metadata_doesnt_migrate_partition in #4680.
Checklist
Please provide the following information:
[x] librdkafka version (2.1.0)
[ ] Apache Kafka version: <REPLACE with e.g., 0.10.2.3>
Description
A partition migration can happen, using stale metadata, when the partition is validating a
next_fetch_startand retring the validation. It can use stale metadata with an invalid leader epoch and migrate back to the previous leader. Later this is corrected but it's sub-optimal.How to reproduce
Execute test
0146/do_test_stale_metadata_doesnt_migrate_partitionin #4680.Checklist
Please provide the following information:
<REPLACE with e.g., 0.10.2.3><REPLACE with e.g., message.timeout.ms=123, auto.reset.offset=earliest, ..><REPLACE with e.g., Centos 5 (x64)>debug=..as necessary) from librdkafka