diff --git a/.github/workflows/vuln.yml b/.github/workflows/vuln.yml deleted file mode 100644 index 497ae80b..00000000 --- a/.github/workflows/vuln.yml +++ /dev/null @@ -1,19 +0,0 @@ -name: govulncheck - -on: - push: - branches: ["*"] - paths-ignore: - - '**/*.md' - pull_request: - branches: ["*"] - paths-ignore: - - '**/*.md' - -jobs: - vulncheck: - runs-on: ubuntu-latest - name: govulncheck - steps: - - id: govulncheck - uses: golang/govulncheck-action@v1 diff --git a/pkg/kgo/source.go b/pkg/kgo/source.go index 316eee27..603b0864 100644 --- 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