We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d107ec7 commit d9611b7Copy full SHA for d9611b7
src/test/java/com/simplesteph/kafka/model/IssueTest.java
@@ -1,5 +1,6 @@
1
package com.simplesteph.kafka.model;
2
3
+import com.simplesteph.kafka.GitHubSchemas;
4
import com.simplesteph.kafka.GitHubSourceTask;
5
import org.apache.kafka.connect.data.Struct;
6
import org.json.JSONObject;
@@ -93,7 +94,7 @@ public void convertsToStruct(){
93
94
// issue
95
Issue issue = Issue.fromJson(issueJson);
96
Struct struct = new GitHubSourceTask().buildRecordValue(issue);
- assert struct.get("created_at").getClass() == Date.class;
97
+ assert struct.get(GitHubSchemas.CREATED_AT_FIELD).getClass() == Date.class;
98
}
99
100
0 commit comments