Demonstrte nil WriteOption is handled

stewartbzillow · stewartbzillow · commit da00f89d8ff8 · 2025-01-23T20:07:08.000-08:00
diff --git a/test/integration_test.go b/test/integration_test.go
@@ -1313,7 +1313,7 @@ func Test_DeadletterClientDoesntCollideWithProducer(t *testing.T) {
 		if msgCount.Load()%2 == 0 {
 			return errors.New("random error occurred")
 		}
-		_, err := processorWriter.WriteRaw(ctx, nil, msg.Value())
+		_, err := processorWriter.WriteRaw(ctx, nil, msg.Value(), nil)
 
 		return err
 	})

Original file line number	Diff line number	Diff line change
`@@ -1313,7 +1313,7 @@ func Test_DeadletterClientDoesntCollideWithProducer(t *testing.T) {`
`1313`	`1313`	`if msgCount.Load()%2 == 0 {`
`1314`	`1314`	`return errors.New("random error occurred")`
`1315`	`1315`	`}`
`1316`		`- _, err := processorWriter.WriteRaw(ctx, nil, msg.Value())`
	`1316`	`+ _, err := processorWriter.WriteRaw(ctx, nil, msg.Value(), nil)`
`1317`	`1317`
`1318`	`1318`	`return err`
`1319`	`1319`	`})`