kgo: add missing debug statement for testing

twmb · May 9, 2024 · 523c702 · 523c702
1 parent bf1d48a
commit 523c702
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/kgo/sink.go b/pkg/kgo/sink.go
@@ -721,7 +721,9 @@ func (s *sink) handleReqRespBatch(
 	batch.owner.okOnSink = false
 
 	if moving := kmove.maybeAddProducePartition(resp, rp, batch.owner); moving {
-		fmt.Fprintf(b, "move:%d:%d@%d,%d}, ", rp.CurrentLeader.LeaderID, rp.CurrentLeader.LeaderEpoch, rp.BaseOffset, nrec)
+		if debug {
+			fmt.Fprintf(b, "move:%d:%d@%d,%d}, ", rp.CurrentLeader.LeaderID, rp.CurrentLeader.LeaderEpoch, rp.BaseOffset, nrec)
+		}
 		batch.owner.failing = true
 		return true, false
 	}