sjhajharia opened a new pull request, #22576:
URL: https://github.com/apache/kafka/pull/22576
### Description
As part of the ongoing effort to migrate `kafka.coordinator.transaction`
from Scala (core) to Java (the transaction-coordinator module), this PR moves
the self-contained "leaf" classes - pure data holders and a stateful helper
with no ReplicaManager/KafkaConfig coupling. These can move independently while
the remaining Scala classes continue to compile against them, since core
depends on transaction-coordinator.
### Changes
- The three data classes become Java records. PendingCompleteTxn keeps a
custom toString to preserve the original log output format.
- TxnMarkerQueue becomes a plain Java class: kafka.utils.Logging → SLF4J,
Scala getOrElseUpdate → computeIfAbsent, and Option → Optional on the public
API.
- Scala call sites updated
- Import repointed in KafkaApis.scala and the affected test files.
--
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]
