Merge pull request #758 from twmb/isolation_level

kgo: ignore aborted txns if using READ_UNCOMMITTED
twmb · Jun 8, 2024 · 40589af · 40589af
2 parents a5b1d0c + 9e32bf9
commit 40589af
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 20 deletions.
diff --git a/.github/workflows/vuln.yml b/.github/workflows/vuln.yml
diff --git a/pkg/kgo/source.go b/pkg/kgo/source.go
@@ -1192,7 +1192,10 @@ func (o *cursorOffsetNext) processRespPartition(br *broker, rp *kmsg.FetchRespon
 		o.hwm = rp.HighWatermark
 	}
 
-	aborter := buildAborter(rp)
+	var aborter aborter
+	if br.cl.cfg.isolationLevel == 1 {
+		aborter = buildAborter(rp)
+	}
 
 	// A response could contain any of message v0, message v1, or record
 	// batches, and this is solely dictated by the magic byte (not the