Skip to content

Commit 40589af

Browse files
authored
Merge pull request #758 from twmb/isolation_level
kgo: ignore aborted txns if using READ_UNCOMMITTED
2 parents a5b1d0c + 9e32bf9 commit 40589af

File tree

2 files changed

+4
-20
lines changed

2 files changed

+4
-20
lines changed

Diff for: .github/workflows/vuln.yml

-19
This file was deleted.

Diff for: pkg/kgo/source.go

+4-1
Original file line numberDiff line numberDiff line change
@@ -1192,7 +1192,10 @@ func (o *cursorOffsetNext) processRespPartition(br *broker, rp *kmsg.FetchRespon
11921192
o.hwm = rp.HighWatermark
11931193
}
11941194

1195-
aborter := buildAborter(rp)
1195+
var aborter aborter
1196+
if br.cl.cfg.isolationLevel == 1 {
1197+
aborter = buildAborter(rp)
1198+
}
11961199

11971200
// A response could contain any of message v0, message v1, or record
11981201
// batches, and this is solely dictated by the magic byte (not the

0 commit comments

Comments
 (0)