{"action":"created","comment":{"url":"https://api.github.com/repos/LigaData/Kamanja/pulls/comments/127102578","pull_request_review_id":49651953,"id":127102578,"diff_hunk":"@@ -348,14 +348,34 @@ public void run() {\n \n \t\t\tif (processor != null)\n \t\t\t    processor.clearAll();\n-\t\t\tlong endWrite = System.currentTimeMillis();\n-\t\t\tif (consumer != null)\n-\t\t\t    consumer.commitSync();\n-\t\t\ttotalMessageCount += messageCount;\n-\t\t\tlogger.info(\"Saved \" + messageCount\n-\t\t\t\t+ \" messages (Total:\" + totalMessageCount\n-\t\t\t\t+ \"). Write time \" + (endWrite - endRead)\n-\t\t\t\t+ \" msecs.\");\n+\n+\t\t\tboolean tryToCommiFlag = true;\n+\t\t\tint countOfCommitRetry = 1;\n+\n+\t\t\t//tryToCommitAgain from continue\n+\t\t\ttryToCommitAgain:\n+\t\t\twhile(tryToCommiFlag) {\n+\t\t\t\tlong endWrite = System.currentTimeMillis();\n+\t\t\t\ttry {\n+\t\t\t\t\tif (consumer != null)\n+\t\t\t\t\t\tconsumer.commitSync();\n+\t\t\t\t\ttotalMessageCount += messageCount;\n+\t\t\t\t\tlogger.info(\"Saved \" + messageCount\n+\t\t\t\t\t\t\t+ \" messages (Total:\" + totalMessageCount\n+\t\t\t\t\t\t\t+ \"). Write time \" + (endWrite - endRead)\n+\t\t\t\t\t\t\t+ \" msecs.\");\n+\n+\t\t\t\t\ttryToCommiFlag = false;\n+\n+\t\t\t\t} catch (CommitFailedException e) {\n+\t\t\t\t\t// keep on trying\n+\t\t\t\t\tlogger.error(\"Failed with: \" + e.getMessage(), e);\n+\t\t\t\t\tlogger.warn(\"Retrying to commit kafka offset number of retries \" + countOfCommitRetry++);\n+\t\t\t\t\tThread.sleep(1000);\n+\n+\t\t\t\t\tcontinue tryToCommitAgain; //goto tryToCommitAgain","path":"trunk/Utils/OutputUtils/src/main/java/com/ligadata/adapters/MessageConsumer.java","position":59,"original_position":59,"commit_id":"c804104e12cdbd8abb15498f1336ff29852c3246","original_commit_id":"c804104e12cdbd8abb15498f1336ff29852c3246","user":{"login":"ligadata-bruce","id":25186128,"avatar_url":"https://avatars1.githubusercontent.com/u/25186128?v=3","gravatar_id":"","url":"https://api.github.com/users/ligadata-bruce","html_url":"https://github.com/ligadata-bruce","followers_url":"https://api.github.com/users/ligadata-bruce/followers","following_url":"https://api.github.com/users/ligadata-bruce/following{/other_user}","gists_url":"https://api.github.com/users/ligadata-bruce/gists{/gist_id}","starred_url":"https://api.github.com/users/ligadata-bruce/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ligadata-bruce/subscriptions","organizations_url":"https://api.github.com/users/ligadata-bruce/orgs","repos_url":"https://api.github.com/users/ligadata-bruce/repos","events_url":"https://api.github.com/users/ligadata-bruce/events{/privacy}","received_events_url":"https://api.github.com/users/ligadata-bruce/received_events","type":"User","site_admin":false},"body":"continue needed? The while loop won't be sufficient?","created_at":"2017-07-13T00:10:30Z","updated_at":"2017-07-13T00:10:37Z","html_url":"https://github.com/LigaData/Kamanja/pull/1631#discussion_r127102578","pull_request_url":"https://api.github.com/repos/LigaData/Kamanja/pulls/1631","_links":{"self":{"href":"https://api.github.com/repos/LigaData/Kamanja/pulls/comments/127102578"},"html":{"href":"https://github.com/LigaData/Kamanja/pull/1631#discussion_r127102578"},"pull_request":{"href":"https://api.github.com/repos/LigaData/Kamanja/pulls/1631"}}},"pull_request":{"url":"https://api.github.com/repos/LigaData/Kamanja/pulls/1631","id":130101290,"html_url":"https://github.com/LigaData/Kamanja/pull/1631","diff_url":"https://github.com/LigaData/Kamanja/pull/1631.diff","patch_url":"https://github.com/LigaData/Kamanja/pull/1631.patch","issue_url":"https://api.github.com/repos/LigaData/Kamanja/issues/1631","number":1631,"state":"open","locked":false,"title":"1.6.2 berkley flr 789","user":{"login":"ligadata-saleh","id":10954986,"avatar_url":"https://avatars1.githubusercontent.com/u/10954986?v=3","gravatar_id":"","url":"https://api.github.com/users/ligadata-saleh","html_url":"https://github.com/ligadata-saleh","followers_url":"https://api.github.com/users/ligadata-saleh/followers","following_url":"https://api.github.com/users/ligadata-saleh/following{/other_user}","gists_url":"https://api.github.com/users/ligadata-saleh/gists{/gist_id}","starred_url":"https://api.github.com/users/ligadata-saleh/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ligadata-saleh/subscriptions","organizations_url":"https://api.github.com/users/ligadata-saleh/orgs","repos_url":"https://api.github.com/users/ligadata-saleh/repos","events_url":"https://api.github.com/users/ligadata-saleh/events{/privacy}","received_events_url":"https://api.github.com/users/ligadata-saleh/received_events","type":"User","site_admin":false},"body":"","created_at":"2017-07-12T10:07:40Z","updated_at":"2017-07-13T00:10:37Z","closed_at":null,"merged_at":null,"merge_commit_sha":"1630fb282b923ebfbfd42e22cdc473be200c42d4","assignee":null,"assignees":[],"requested_reviewers":[{"login":"ligadata-pokuri","id":8701908,"avatar_url":"https://avatars0.githubusercontent.com/u/8701908?v=3","gravatar_id":"","url":"https://api.github.com/users/ligadata-pokuri","html_url":"https://github.com/ligadata-pokuri","followers_url":"https://api.github.com/users/ligadata-pokuri/followers","following_url":"https://api.github.com/users/ligadata-pokuri/following{/other_user}","gists_url":"https://api.github.com/users/ligadata-pokuri/gists{/gist_id}","starred_url":"https://api.github.com/users/ligadata-pokuri/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ligadata-pokuri/subscriptions","organizations_url":"https://api.github.com/users/ligadata-pokuri/orgs","repos_url":"https://api.github.com/users/ligadata-pokuri/repos","events_url":"https://api.github.com/users/ligadata-pokuri/events{/privacy}","received_events_url":"https://api.github.com/users/ligadata-pokuri/received_events","type":"User","site_admin":false}],"milestone":null,"commits_url":"https://api.github.com/repos/LigaData/Kamanja/pulls/1631/commits","review_comments_url":"https://api.github.com/repos/LigaData/Kamanja/pulls/1631/comments","review_comment_url":"https://api.github.com/repos/LigaData/Kamanja/pulls/comments{/number}","comments_url":"https://api.github.com/repos/LigaData/Kamanja/issues/1631/comments","statuses_url":"https://api.github.com/repos/LigaData/Kamanja/statuses/c804104e12cdbd8abb15498f1336ff29852c3246","head":{"label":"LigaData:1.6.2-Berkley_FLR-789","ref":"1.6.2-Berkley_FLR-789","sha":"c804104e12cdbd8abb15498f1336ff29852c3246","user":{"login":"LigaData","id":8631713,"avatar_url":"https://avatars2.githubusercontent.com/u/8631713?v=3","gravatar_id":"","url":"https://api.github.com/users/LigaData","html_url":"https://github.com/LigaData","followers_url":"https://api.github.com/users/LigaData/followers","following_url":"https://api.github.com/users/LigaData/following{/other_user}","gists_url":"https://api.github.com/users/LigaData/gists{/gist_id}","starred_url":"https://api.github.com/users/LigaData/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/LigaData/subscriptions","organizations_url":"https://api.github.com/users/LigaData/orgs","repos_url":"https://api.github.com/users/LigaData/repos","events_url":"https://api.github.com/users/LigaData/events{/privacy}","received_events_url":"https://api.github.com/users/LigaData/received_events","type":"Organization","site_admin":false},"repo":{"id":23932086,"name":"Kamanja","full_name":"LigaData/Kamanja","owner":{"login":"LigaData","id":8631713,"avatar_url":"https://avatars2.githubusercontent.com/u/8631713?v=3","gravatar_id":"","url":"https://api.github.com/users/LigaData","html_url":"https://github.com/LigaData","followers_url":"https://api.github.com/users/LigaData/followers","following_url":"https://api.github.com/users/LigaData/following{/other_user}","gists_url":"https://api.github.com/users/LigaData/gists{/gist_id}","starred_url":"https://api.github.com/users/LigaData/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/LigaData/subscriptions","organizations_url":"https://api.github.com/users/LigaData/orgs","repos_url":"https://api.github.com/users/LigaData/repos","events_url":"https://api.github.com/users/LigaData/events{/privacy}","received_events_url":"https://api.github.com/users/LigaData/received_events","type":"Organization","site_admin":false},"private":false,"html_url":"https://github.com/LigaData/Kamanja","description":"Kamanja is an open-source continuous decisioning engine that is hardened for enterprise reliability requirements, scalable to IoT level data volumes, and enables low latency use cases","fork":false,"url":"https://api.github.com/repos/LigaData/Kamanja","forks_url":"https://api.github.com/repos/LigaData/Kamanja/forks","keys_url":"https://api.github.com/repos/LigaData/Kamanja/keys{/key_id}","collaborators_url":"https://api.github.com/repos/LigaData/Kamanja/collaborators{/collaborator}","teams_url":"https://api.github.com/repos/LigaData/Kamanja/teams","hooks_url":"https://api.github.com/repos/LigaData/Kamanja/hooks","issue_events_url":"https://api.github.com/repos/LigaData/Kamanja/issues/events{/number}","events_url":"https://api.github.com/repos/LigaData/Kamanja/events","assignees_url":"https://api.github.com/repos/LigaData/Kamanja/assignees{/user}","branches_url":"https://api.github.com/repos/LigaData/Kamanja/branches{/branch}","tags_url":"https://api.github.com/repos/LigaData/Kamanja/tags","blobs_url":"https://api.github.com/repos/LigaData/Kamanja/git/blobs{/sha}","git_tags_url":"https://api.github.com/repos/LigaData/Kamanja/git/tags{/sha}","git_refs_url":"https://api.github.com/repos/LigaData/Kamanja/git/refs{/sha}","trees_url":"https://api.github.com/repos/LigaData/Kamanja/git/trees{/sha}","statuses_url":"https://api.github.com/repos/LigaData/Kamanja/statuses/{sha}","languages_url":"https://api.github.com/repos/LigaData/Kamanja/languages","stargazers_url":"https://api.github.com/repos/LigaData/Kamanja/stargazers","contributors_url":"https://api.github.com/repos/LigaData/Kamanja/contributors","subscribers_url":"https://api.github.com/repos/LigaData/Kamanja/subscribers","subscription_url":"https://api.github.com/repos/LigaData/Kamanja/subscription","commits_url":"https://api.github.com/repos/LigaData/Kamanja/commits{/sha}","git_commits_url":"https://api.github.com/repos/LigaData/Kamanja/git/commits{/sha}","comments_url":"https://api.github.com/repos/LigaData/Kamanja/comments{/number}","issue_comment_url":"https://api.github.com/repos/LigaData/Kamanja/issues/comments{/number}","contents_url":"https://api.github.com/repos/LigaData/Kamanja/contents/{+path}","compare_url":"https://api.github.com/repos/LigaData/Kamanja/compare/{base}...{head}","merges_url":"https://api.github.com/repos/LigaData/Kamanja/merges","archive_url":"https://api.github.com/repos/LigaData/Kamanja/{archive_format}{/ref}","downloads_url":"https://api.github.com/repos/LigaData/Kamanja/downloads","issues_url":"https://api.github.com/repos/LigaData/Kamanja/issues{/number}","pulls_url":"https://api.github.com/repos/LigaData/Kamanja/pulls{/number}","milestones_url":"https://api.github.com/repos/LigaData/Kamanja/milestones{/number}","notifications_url":"https://api.github.com/repos/LigaData/Kamanja/notifications{?since,all,participating}","labels_url":"https://api.github.com/repos/LigaData/Kamanja/labels{/name}","releases_url":"https://api.github.com/repos/LigaData/Kamanja/releases{/id}","deployments_url":"https://api.github.com/repos/LigaData/Kamanja/deployments","created_at":"2014-09-11T19:13:31Z","updated_at":"2017-05-30T07:37:44Z","pushed_at":"2017-07-12T23:42:44Z","git_url":"git://github.com/LigaData/Kamanja.git","ssh_url":"git@github.com:LigaData/Kamanja.git","clone_url":"https://github.com/LigaData/Kamanja.git","svn_url":"https://github.com/LigaData/Kamanja","homepage":"http://www.kamanja.org","size":191726,"stargazers_count":37,"watchers_count":37,"language":"Scala","has_issues":true,"has_projects":true,"has_downloads":true,"has_wiki":true,"has_pages":true,"forks_count":13,"mirror_url":null,"open_issues_count":152,"forks":13,"open_issues":152,"watchers":37,"default_branch":"dev"}},"base":{"label":"LigaData:1.6.2-Berkley","ref":"1.6.2-Berkley","sha":"1dc78610b241674296b53d06889c424cc525f673","user":{"login":"LigaData","id":8631713,"avatar_url":"https://avatars2.githubusercontent.com/u/8631713?v=3","gravatar_id":"","url":"https://api.github.com/users/LigaData","html_url":"https://github.com/LigaData","followers_url":"https://api.github.com/users/LigaData/followers","following_url":"https://api.github.com/users/LigaData/following{/other_user}","gists_url":"https://api.github.com/users/LigaData/gists{/gist_id}","starred_url":"https://api.github.com/users/LigaData/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/LigaData/subscriptions","organizations_url":"https://api.github.com/users/LigaData/orgs","repos_url":"https://api.github.com/users/LigaData/repos","events_url":"https://api.github.com/users/LigaData/events{/privacy}","received_events_url":"https://api.github.com/users/LigaData/received_events","type":"Organization","site_admin":false},"repo":{"id":23932086,"name":"Kamanja","full_name":"LigaData/Kamanja","owner":{"login":"LigaData","id":8631713,"avatar_url":"https://avatars2.githubusercontent.com/u/8631713?v=3","gravatar_id":"","url":"https://api.github.com/users/LigaData","html_url":"https://github.com/LigaData","followers_url":"https://api.github.com/users/LigaData/followers","following_url":"https://api.github.com/users/LigaData/following{/other_user}","gists_url":"https://api.github.com/users/LigaData/gists{/gist_id}","starred_url":"https://api.github.com/users/LigaData/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/LigaData/subscriptions","organizations_url":"https://api.github.com/users/LigaData/orgs","repos_url":"https://api.github.com/users/LigaData/repos","events_url":"https://api.github.com/users/LigaData/events{/privacy}","received_events_url":"https://api.github.com/users/LigaData/received_events","type":"Organization","site_admin":false},"private":false,"html_url":"https://github.com/LigaData/Kamanja","description":"Kamanja is an open-source continuous decisioning engine that is hardened for enterprise reliability requirements, scalable to IoT level data volumes, and enables low latency use cases","fork":false,"url":"https://api.github.com/repos/LigaData/Kamanja","forks_url":"https://api.github.com/repos/LigaData/Kamanja/forks","keys_url":"https://api.github.com/repos/LigaData/Kamanja/keys{/key_id}","collaborators_url":"https://api.github.com/repos/LigaData/Kamanja/collaborators{/collaborator}","teams_url":"https://api.github.com/repos/LigaData/Kamanja/teams","hooks_url":"https://api.github.com/repos/LigaData/Kamanja/hooks","issue_events_url":"https://api.github.com/repos/LigaData/Kamanja/issues/events{/number}","events_url":"https://api.github.com/repos/LigaData/Kamanja/events","assignees_url":"https://api.github.com/repos/LigaData/Kamanja/assignees{/user}","branches_url":"https://api.github.com/repos/LigaData/Kamanja/branches{/branch}","tags_url":"https://api.github.com/repos/LigaData/Kamanja/tags","blobs_url":"https://api.github.com/repos/LigaData/Kamanja/git/blobs{/sha}","git_tags_url":"https://api.github.com/repos/LigaData/Kamanja/git/tags{/sha}","git_refs_url":"https://api.github.com/repos/LigaData/Kamanja/git/refs{/sha}","trees_url":"https://api.github.com/repos/LigaData/Kamanja/git/trees{/sha}","statuses_url":"https://api.github.com/repos/LigaData/Kamanja/statuses/{sha}","languages_url":"https://api.github.com/repos/LigaData/Kamanja/languages","stargazers_url":"https://api.github.com/repos/LigaData/Kamanja/stargazers","contributors_url":"https://api.github.com/repos/LigaData/Kamanja/contributors","subscribers_url":"https://api.github.com/repos/LigaData/Kamanja/subscribers","subscription_url":"https://api.github.com/repos/LigaData/Kamanja/subscription","commits_url":"https://api.github.com/repos/LigaData/Kamanja/commits{/sha}","git_commits_url":"https://api.github.com/repos/LigaData/Kamanja/git/commits{/sha}","comments_url":"https://api.github.com/repos/LigaData/Kamanja/comments{/number}","issue_comment_url":"https://api.github.com/repos/LigaData/Kamanja/issues/comments{/number}","contents_url":"https://api.github.com/repos/LigaData/Kamanja/contents/{+path}","compare_url":"https://api.github.com/repos/LigaData/Kamanja/compare/{base}...{head}","merges_url":"https://api.github.com/repos/LigaData/Kamanja/merges","archive_url":"https://api.github.com/repos/LigaData/Kamanja/{archive_format}{/ref}","downloads_url":"https://api.github.com/repos/LigaData/Kamanja/downloads","issues_url":"https://api.github.com/repos/LigaData/Kamanja/issues{/number}","pulls_url":"https://api.github.com/repos/LigaData/Kamanja/pulls{/number}","milestones_url":"https://api.github.com/repos/LigaData/Kamanja/milestones{/number}","notifications_url":"https://api.github.com/repos/LigaData/Kamanja/notifications{?since,all,participating}","labels_url":"https://api.github.com/repos/LigaData/Kamanja/labels{/name}","releases_url":"https://api.github.com/repos/LigaData/Kamanja/releases{/id}","deployments_url":"https://api.github.com/repos/LigaData/Kamanja/deployments","created_at":"2014-09-11T19:13:31Z","updated_at":"2017-05-30T07:37:44Z","pushed_at":"2017-07-12T23:42:44Z","git_url":"git://github.com/LigaData/Kamanja.git","ssh_url":"git@github.com:LigaData/Kamanja.git","clone_url":"https://github.com/LigaData/Kamanja.git","svn_url":"https://github.com/LigaData/Kamanja","homepage":"http://www.kamanja.org","size":191726,"stargazers_count":37,"watchers_count":37,"language":"Scala","has_issues":true,"has_projects":true,"has_downloads":true,"has_wiki":true,"has_pages":true,"forks_count":13,"mirror_url":null,"open_issues_count":152,"forks":13,"open_issues":152,"watchers":37,"default_branch":"dev"}},"_links":{"self":{"href":"https://api.github.com/repos/LigaData/Kamanja/pulls/1631"},"html":{"href":"https://github.com/LigaData/Kamanja/pull/1631"},"issue":{"href":"https://api.github.com/repos/LigaData/Kamanja/issues/1631"},"comments":{"href":"https://api.github.com/repos/LigaData/Kamanja/issues/1631/comments"},"review_comments":{"href":"https://api.github.com/repos/LigaData/Kamanja/pulls/1631/comments"},"review_comment":{"href":"https://api.github.com/repos/LigaData/Kamanja/pulls/comments{/number}"},"commits":{"href":"https://api.github.com/repos/LigaData/Kamanja/pulls/1631/commits"},"statuses":{"href":"https://api.github.com/repos/LigaData/Kamanja/statuses/c804104e12cdbd8abb15498f1336ff29852c3246"}}}}
{"actor":{"display_login":"ligadata-bruce"}}