From bf37dfa9bacf6d80dd22ba99973f1910db060de6 Mon Sep 17 00:00:00 2001 From: jacob Date: Tue, 21 Feb 2023 11:54:17 -0600 Subject: [PATCH] add name field to recordTime field --- idk/kafka/source.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 }