rreddy-22 opened a new pull request, #20868: URL: https://github.com/apache/kafka/pull/20868
In this patch, we add a new WriteTxnMarkersRequest builder constructor that accepts transaction versions for each marker. The transaction version is already stored in the metadata on the transaction coordinator. We now extract this version information and pass it to the builder, which propagates it to partition leaders. Since the TransactionVersion field is marked as ignorable, we always include it when building the request. The field will be automatically omitted without any errors, during serialization if the request version is < 2, ensuring backward compatibility with brokers that only support version 1. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
