diff --git a/idk/kafka/source.go b/idk/kafka/source.go
index bcc519d20..003c8d76f 100644
--- a/idk/kafka/source.go
+++ b/idk/kafka/source.go
@@ -648,7 +648,8 @@ func avroToPDKField(aField *avro.SchemaField) (idk.Field, error) {
 				return nil, errors.Errorf("required property for RecordTimeField: layout, err:%v", err)
 			}
 			return idk.RecordTimeField{
-				Layout: layout,
+				NameVal: aField.Name,
+				Layout:  layout,
 			}, nil
 		}