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 {