updated struct and schema to leverage the timestamp type

Author: simplesteph

src/main/java/com/simplesteph/kafka/GitHubSourceTask.java

@@ -137,14 +137,14 @@ private Struct buildRecordKey(Issue issue){
         return key;
     }
 
-    private Struct buildRecordValue(Issue issue){
+    public Struct buildRecordValue(Issue issue){
 
         // Issue top level fields
         Struct valueStruct = new Struct(VALUE_SCHEMA)
                 .put(URL_FIELD, issue.getUrl())
                 .put(TITLE_FIELD, issue.getTitle())
-                .put(CREATED_AT_FIELD, issue.getCreatedAt().toEpochMilli())
-                .put(UPDATED_AT_FIELD, issue.getUpdatedAt().toEpochMilli())
+                .put(CREATED_AT_FIELD, Date.from(issue.getCreatedAt()))
+                .put(UPDATED_AT_FIELD, Date.from(issue.getUpdatedAt()))
                 .put(NUMBER_FIELD, issue.getNumber())
                 .put(STATE_FIELD, issue.getState());
 

src/test/java/com/simplesteph/kafka/model/IssueTest.java

@@ -1,8 +1,12 @@
 package com.simplesteph.kafka.model;
 
+import com.simplesteph.kafka.GitHubSourceTask;
+import org.apache.kafka.connect.data.Struct;
 import org.json.JSONObject;
 import org.junit.Test;
 
+import java.util.Date;
+
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertNotNull;
 
@@ -84,4 +88,12 @@ public void canParseJson(){
 
     }
 
+    @Test
+    public void convertsToStruct(){
+        // issue
+        Issue issue = Issue.fromJson(issueJson);
+        Struct struct = new GitHubSourceTask().buildRecordValue(issue);
+        assert struct.get("created_at").getClass() == Date.class;
+    }
+
 }