kotlin-kafka icon indicating copy to clipboard operation
kotlin-kafka copied to clipboard

Investigate TransactionManager using Kotlin suspend DSL

Open nomisRev opened this issue 2 years ago • 0 comments
trafficstars

We should add a TransactionManager with following signatures, but ideally it should work through a Kotlin suspend DSL.

Idea:

manager.transaction {

  // abort(), if aborted it doesn't commit
} // auto-commit, if lambda successfully worked without a call to `abort()`

Should be possible to install some listeners to manager.

manager.onComplete { didComplete: Boolean -> }

nomisRev avatar Oct 06 '23 14:10 nomisRev