diff --git a/pkg/sources/forward/data_forward_test.go b/pkg/sources/forward/data_forward_test.go
index e4fb00a2e0..96cb6760e6 100644
--- a/pkg/sources/forward/data_forward_test.go
+++ b/pkg/sources/forward/data_forward_test.go
@@ -883,7 +883,7 @@ func (f mySourceForwardTest) ApplyTransform(ctx context.Context, messages []*isb
 		}
 		results[i] = isb.ReadWriteMessagePair{
 			ReadMessage: message,
-			WriteMessages: []*isb.WriteMessage{&isb.WriteMessage{
+			WriteMessages: []*isb.WriteMessage{{
 				Message: writeMsg,
 			}},
 		}