zhangshenghang opened a new pull request, #11588: URL: https://github.com/apache/seatunnel/pull/11588
## Summary Fixes #10061. Kafka transaction recovery now creates a fresh temporary producer for each transactional ID being checked. Reusing one producer while mutating its transactional ID could retain a non-zero epoch indefinitely and leave the cleanup loop running forever. Each temporary producer is closed after its check. ## Tests - Added a unit test covering a recovered transaction followed by the first unused transactional ID. - `./mvnw -q -pl seatunnel-connectors-v2/connector-kafka -Dtest=KafkaTransactionSenderTest test` - `./mvnw -q -pl seatunnel-connectors-v2/connector-kafka test` - `./mvnw -q -pl seatunnel-connectors-v2/connector-kafka -DskipTests verify` -- 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]
