From d64acc1364d8f9b1b269de3390f142fd66ddf003 Mon Sep 17 00:00:00 2001 From: Keran Yang Date: Thu, 15 Aug 2024 12:48:22 -0400 Subject: [PATCH] . Signed-off-by: Keran Yang --- pkg/sourcetransformer/examples/assign_event_time/main.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/sourcetransformer/examples/assign_event_time/main.go b/pkg/sourcetransformer/examples/assign_event_time/main.go index b1b1a01b..d53c2326 100644 --- a/pkg/sourcetransformer/examples/assign_event_time/main.go +++ b/pkg/sourcetransformer/examples/assign_event_time/main.go @@ -15,6 +15,8 @@ type AssignEventTime struct { func (a *AssignEventTime) Transform(ctx context.Context, keys []string, d sourcetransformer.Datum) sourcetransformer.Messages { // Update message event time to time.Now() eventTime := time.Now() + // Log the action so that we can use it for testing. + log.Printf("AssignEventTime: Assigning event time %v to message %s", eventTime, string(d.Value())) return sourcetransformer.MessagesBuilder().Append(sourcetransformer.NewMessage(d.Value(), eventTime).WithKeys(keys)) }