From 864c6ad4e772f7a1d019c8250d85fc42f17eb5b5 Mon Sep 17 00:00:00 2001
From: jacob <jrbrinlee1@gmail.com>
Date: Tue, 21 Feb 2023 13:23:43 -0600
Subject: [PATCH] adding test avro to PDK for recordTime

---
 idk/kafka/source_test.go | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/idk/kafka/source_test.go b/idk/kafka/source_test.go
index 0738bc753..e695cba11 100644
--- a/idk/kafka/source_test.go
+++ b/idk/kafka/source_test.go
@@ -226,6 +226,19 @@ func TestAvroToPDKField(t *testing.T) {
 			expField: idk.IDField{NameVal: "int-ttl"},
 			expErr:   "nil",
 		},
+		{
+			name: "recordTime",
+			schemaField: &avro.SchemaField{
+				Name: "record-time",
+				Type: &avro.BytesSchema{},
+				Properties: map[string]interface{}{
+					"layout":    "2006-01-02 15:04:05",
+					"fieldType": "recordTime",
+				},
+			},
+			expField: idk.RecordTimeField{NameVal: "record-time", Layout: "2006-01-02 15:04:05"},
+			expErr:   "nil",
+		},
 	}
 
 	for _, test := range tests {