Skip to content

Commit 6921826

Browse files
committed
quick fix to issue and sourcePartition
1 parent b490a1a commit 6921826

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -197,8 +197,9 @@ public void stop() {
197197
}
198198

199199
private Map<String, String> sourcePartition() {
200-
Map<String, String> map = Collections.singletonMap(FULL_REPO_FIELD,
201-
config.getOwnerConfig() + "/" + config.getRepoConfig());
200+
Map<String, String> map = new HashMap<>();
201+
map.put(OWNER_FIELD, config.getOwnerConfig());
202+
map.put(REPOSITORY_FIELD, config.getRepoConfig());
202203
return map;
203204
}
204205

src/main/java/com/simplesteph/kafka/model/Issue.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -410,7 +410,6 @@ public static Issue fromJson(JSONObject jsonObject) {
410410

411411
// pull request is an optional fields
412412
if (jsonObject.has("pull_request")){
413-
System.out.println("pull!");
414413
PullRequest pullRequest = PullRequest.fromJson(jsonObject.getJSONObject("pull_request"));
415414
issue.withPullRequest(pullRequest);
416415
}

0 commit comments

Comments
 (0)