search

akka / alpakka-kafka

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
https://doc.akka.io/libraries/alpakka-kafka/current/
Other
1.42k stars 386 forks source link

feat: Add transaction prefix option #1733

Closed JustinPihony closed 7 months ago

JustinPihony commented 7 months ago

An add-on to #1728 for a bit more configurability

johanandren commented 7 months ago

Added some fixes, instead of waiting for a review cycle.

sebastian-alfers commented 7 months ago

Should we think about adding a spec for this?

johanandren commented 7 months ago

I don't think we can observe the transaction id in any reasonable way in a test without a lot of effort, so probably not worth it.

johanandren commented 7 months ago

We can try running one of the existing test cases with a prefix specified though.