mjsax opened a new pull request, #24020: URL: https://github.com/apache/kafka/pull/24020
SubscriptionSendProcessorSupplier took the primary partition from the record metadata, which is -1 for records forwarded from a punctuator. The response is then sent to partition -1 and fails the task. Use the partition of the task instead, which is the partition of the left-table record in all cases. -- 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]
