Skip to content

Commit bfa4819

Browse files
committed
namespacing schema according to confluent guidelines
1 parent f51ecea commit bfa4819

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -31,10 +31,10 @@ public class GitHubSchemas {
3131
public static String PR_HTML_URL_FIELD = "html_url";
3232

3333
// Schema names
34-
public static String SCHEMA_KEY = "issue_key";
35-
public static String SCHEMA_VALUE_ISSUE = "issue";
36-
public static String SCHEMA_VALUE_USER = "user";
37-
public static String SCHEMA_VALUE_PR = "pr";
34+
public static String SCHEMA_KEY = "com.simplesteph.kafka.connect.github.IssueKey";
35+
public static String SCHEMA_VALUE_ISSUE = "com.simplesteph.kafka.connect.github.IssueValue";
36+
public static String SCHEMA_VALUE_USER = "com.simplesteph.kafka.connect.github.UserValue";
37+
public static String SCHEMA_VALUE_PR = "com.simplesteph.kafka.connect.github.PrValue";
3838

3939
// Key Schema
4040
public static Schema KEY_SCHEMA = SchemaBuilder.struct().name(SCHEMA_KEY)

0 commit comments

Comments
 (0)