[WIP] KAFKA-8729, pt 4: Add client-side logic to augment error handling and partially fail records specified in error_records#7168
Conversation
|
Depending on #7150 to be merged |
34e70fb to
2a94c0e
Compare
|
retest this please |
8f565d8 to
c68e76a
Compare
|
retest this please |
0a24dff to
9aa86c6
Compare
|
This PR is being marked as stale since it has not had any activity in 90 days. If you If you are having difficulty finding a reviewer, please reach out on the [mailing list](https://kafka.apache.org/contact). If this PR is no longer valid or desired, please feel free to close it. If no activity occurs in the next 30 days, it will be automatically closed. |
|
This PR has been closed since it has not had any activity in 120 days. If you feel like this |
Added
Sender#partialFailBatchandProducerBatch#partiallyDoneto only fail and invoke callbacks of records inerror_records.Modified
FutureRecordMetadatato re-bind a record'sProduceRequestResultto that of a new batch.Committer Checklist (excluded from commit message)