Skip to content

Commit 238fd86

Browse files
committed
updated schema to use Connect's Timestamp format.
1 parent bfa4819 commit 238fd86

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

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

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
import org.apache.kafka.connect.data.Schema;
44
import org.apache.kafka.connect.data.SchemaBuilder;
5+
import org.apache.kafka.connect.data.Timestamp;
56

67
public class GitHubSchemas {
78

@@ -61,11 +62,11 @@ public class GitHubSchemas {
6162
.build();
6263

6364
public static Schema VALUE_SCHEMA = SchemaBuilder.struct().name(SCHEMA_VALUE_ISSUE)
64-
.version(1)
65+
.version(2)
6566
.field(URL_FIELD, Schema.STRING_SCHEMA)
6667
.field(TITLE_FIELD, Schema.STRING_SCHEMA)
67-
.field(CREATED_AT_FIELD, Schema.INT64_SCHEMA)
68-
.field(UPDATED_AT_FIELD, Schema.INT64_SCHEMA)
68+
.field(CREATED_AT_FIELD, Timestamp.SCHEMA)
69+
.field(UPDATED_AT_FIELD, Timestamp.SCHEMA)
6970
.field(NUMBER_FIELD, Schema.INT32_SCHEMA)
7071
.field(STATE_FIELD, Schema.STRING_SCHEMA)
7172
.field(USER_FIELD, USER_SCHEMA) // mandatory

0 commit comments

Comments
 (0)