diff --git a/test/integration_test.go b/test/integration_test.go
index 08c1bdf..5a05096 100644
--- 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
 	})