#1428·kafka-go

KIP-890: support for transactions v2

Author: ajeetdsouzaCreated Mar 16, 2026Updated Mar 16, 2026
Labelsenhancement

Describe the solution you would like

Kafka v4.0 fixes a major bug in transactions, which essentially allowed Produce requests from one transaction to "leak" into another transaction. This required breaking changes, so transaction.version = 2 has been introduced in order to fix this.

It seems that segmentio/kafka-go does support Kafka v4.0, but has not yet moved to transactions v2. Since this affects the correctness of transactions, can this feature be brought to the segmentio client soon?

Supporting documentation

https://cwiki.apache.org/confluence/display/KAFKA/KIP-890%3A+Transactions+Server-Side+Defense