{"action":"created","comment":{"url":"https://api.github.com/repos/apache/storm/pulls/comments/56517067","id":56517067,"diff_hunk":"@@ -0,0 +1,298 @@\n+/*\n+ * Licensed to the Apache Software Foundation (ASF) under one\n+ *   or more contributor license agreements.  See the NOTICE file\n+ *   distributed with this work for additional information\n+ *   regarding copyright ownership.  The ASF licenses this file\n+ *   to you under the Apache License, Version 2.0 (the\n+ *   \"License\"); you may not use this file except in compliance\n+ *   with the License.  You may obtain a copy of the License at\n+ *\n+ *   http://www.apache.org/licenses/LICENSE-2.0\n+ *\n+ *   Unless required by applicable law or agreed to in writing, software\n+ *   distributed under the License is distributed on an \"AS IS\" BASIS,\n+ *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n+ *   See the License for the specific language governing permissions and\n+ *   limitations under the License.\n+ */\n+\n+package org.apache.storm.kafka.spout;\n+\n+import org.apache.kafka.common.serialization.Deserializer;\n+\n+import java.io.Serializable;\n+import java.util.ArrayList;\n+import java.util.List;\n+import java.util.Map;\n+\n+/**\n+ * KafkaSpoutConfig defines the required configuration to connect a consumer to a consumer group, as well as the subscribing topics\n+ */\n+public class KafkaSpoutConfig<K, V> implements Serializable {\n+    public static final long DEFAULT_POLL_TIMEOUT_MS = 2_000;            // 2s\n+    public static final long DEFAULT_OFFSET_COMMIT_PERIOD_MS = 15_000;   // 15s\n+    public static final int DEFAULT_MAX_RETRIES = Integer.MAX_VALUE;     // Retry forever\n+    public static final int DEFAULT_MAX_UNCOMMITTED_OFFSETS = 10_000;    // 10,000 records\n+\n+    // Kafka property names\n+    public interface Consumer {\n+        String GROUP_ID = \"group.id\";\n+        String BOOTSTRAP_SERVERS = \"bootstrap.servers\";\n+        String ENABLE_AUTO_COMMIT = \"enable.auto.commit\";\n+        String AUTO_COMMIT_INTERVAL_MS = \"auto.commit.interval.ms\";\n+        String KEY_DESERIALIZER = \"key.deserializer\";\n+        String VALUE_DESERIALIZER = \"value.deserializer\";\n+    }\n+\n+    /**\n+     * The offset used by the Kafka spout in the first poll to Kafka broker. The choice of this parameter will\n+     * affect the number of consumer records returned in the first poll. By default this parameter is set to UNCOMMITTED_EARLIEST. <br/><br/>\n+     * The allowed values are EARLIEST, LATEST, UNCOMMITTED_EARLIEST, UNCOMMITTED_LATEST. <br/>\n+     * <ul>\n+     * <li>EARLIEST means that the kafka spout polls records starting in the first offset of the partition, regardless of previous commits</li>\n+     * <li>LATEST means that the kafka spout polls records with offsets greater than the last offset in the partition, regardless of previous commits</li>\n+     * <li>UNCOMMITTED_EARLIEST means that the kafka spout polls records from the last committed offset, if any.\n+     * If no offset has been committed, it behaves as EARLIEST.</li>\n+     * <li>UNCOMMITTED_LATEST means that the kafka spout polls records from the last committed offset, if any.\n+     * If no offset has been committed, it behaves as LATEST.</li>\n+     * </ul>\n+     * */\n+    public enum FirstPollOffsetStrategy {\n+        EARLIEST,\n+        LATEST,\n+        UNCOMMITTED_EARLIEST,\n+        UNCOMMITTED_LATEST }\n+\n+    /**\n+     * Defines when to poll the next batch of records from Kafka. The choice of this parameter will affect throughput and the memory\n+     * footprint of the Kafka spout. The allowed values are STREAM and BATCH. STREAM will likely have higher throughput and use more memory\n+     * (it stores in memory the entire KafkaRecord,including data). BATCH will likely have less throughput but also use less memory.\n+     * The BATCH behavior is similar to the behavior of the previous Kafka Spout. De default value is STREAM.\n+     * <ul>\n+     *     <li>STREAM Every periodic call to nextTuple polls a new batch of records from Kafka as long as the maxUncommittedOffsets\n+     *     threshold has not yet been reached. When the threshold his reached, no more records are polled until enough offsets have been\n+     *     committed, such that the number of pending offsets is less than maxUncommittedOffsets. See {@link Builder#setMaxUncommittedOffsets(int)}\n+     *     </li>\n+     *     <li>BATCH Only polls a new batch of records from kafka once all the records that came in the previous poll have been acked.</li>\n+     * </ul>\n+     */\n+    public enum PollStrategy {\n+        STREAM,\n+        BATCH","path":"external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java","position":81,"original_position":81,"commit_id":"afc3bdebd70faac9da6af907c18665f47604a012","original_commit_id":"afc3bdebd70faac9da6af907c18665f47604a012","user":{"login":"revans2","id":3441321,"avatar_url":"https://avatars.githubusercontent.com/u/3441321?v=3","gravatar_id":"","url":"https://api.github.com/users/revans2","html_url":"https://github.com/revans2","followers_url":"https://api.github.com/users/revans2/followers","following_url":"https://api.github.com/users/revans2/following{/other_user}","gists_url":"https://api.github.com/users/revans2/gists{/gist_id}","starred_url":"https://api.github.com/users/revans2/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/revans2/subscriptions","organizations_url":"https://api.github.com/users/revans2/orgs","repos_url":"https://api.github.com/users/revans2/repos","events_url":"https://api.github.com/users/revans2/events{/privacy}","received_events_url":"https://api.github.com/users/revans2/received_events","type":"User","site_admin":false},"body":"Now to answer your other question.  It seems like you have thought through this a lot.  Philosophically I think that modular code, with interfaces is usually a good idea, especially for making the code unit testable.  Exposing those to end users and making them pluggable without a really good use case make the code more difficult to maintain because I have to maintain that interface for good or bad.\r\n\r\nI personally would like to reuse a lot of the design from the original spout because we know it works.\r\n\r\n**All of the following describes what the follow on spout should look like unless otherwise stated. My changes/comments are in bold**\r\n\r\n[0] - We fetch (poll) a new set of records from Kafka **when we don't have something to emit from our buffer.  The internal spout flow control assumes that we will emit around one tuple at a time when it calls `.nextTuple()`.  So we have a buffer of messages to emit and emit them one at a time**  \r\n\r\n[1] - If offsets 1 2 3 4 5 6 get fetched (polled)  and the following occurs: 1 2 committed, 4 fails  , 3 5 6 pending **and the exponential back-off for 4 has expired and 4 has been retired less then the maximum number of retries**.\r\n\r\n  * [1.1] - We want to fetch again starting on **4, i.e 4 5 6 ... and then filter out any messages that are not ready to be replayed.**\r\n\r\n  * [1.2] - Let's say 3 that was pending fails after the retry fetch described in [1.1] **(4 5 6 ... )** has happened. What do we do? **We fetch again starting with 3 this time (3 4 5 ...)**\r\n\r\n[2] - **We want in the follow on JIRA** to have some logic to avoid re-emitting **any tuples that have been emitted and not had a corresponding `fail()` called on them yet.  Preferably with some sort of a back-off like the original code.**\r\n\r\n[3] - **We want this patch** to support a limited number of retrials for a particular offset**.** Let's say 4 keeps on failing. **W**e want to limit the number of fails (i.e repeat what is done in [1.1]) to e.g. 3 times, and once the limit is reached, we consider 4 has committed**. In the follow-on patch at a minimum we need a metric to count how many of these we have dropped.**\r\n\r\n  * [3.1] - In this scenario, **we are only replaying failed messages by placing them into the same buffer/queue that we emit from. We will continue to fetch new messages into that queue so long as we have not violated the maxUncommitedOffsets, but we will never commit anything above 4 until it has failed the maximum number of times.  This means we will not violate the guarantee, even if the spout crashes and a new spout looses all of its state, unless we have kafka auto-commit turned on.** \r\n\r\n   * [3.2] - Do we want to stop retrying 4 (even if it has reached max retries) only if all the offsets less than 4 have been acked, or all have failed more than maxNumRetries**? maxNumRetires needs to be marked as a best effort.  If the spout fails before we can persist the data to kafka we may retry the message more often.**\r\n\r\n[4] - We do NOT want at all to have the feature to retry from memory. That means that there is no need to ever keep tuples in memory, only offsets. **Ultimately I think so.  I still have not seen a use case that warrants it.**\r\n\r\n   * [4.1] - Or do we want extract the retry strategy into one interface, and have implementations for both? **Like I said above having an interface that allows us to make it pluggable, especially for unit tests is a great thing, but exposing it to the end user without a good use case is not.**\r\n\r\n[5] - Does it make sense to even support retrying an offset forever? This can potentially cause an infinite cycle of fetch (poll) calls to Kafka accross the network... but it will guarantee delivery up to that point (offset).  **I don't have one, but to work around this not being there I think this is why we have the FirstPollOffsetStrategy so we can pick up in different spot and skip something that is bad**\r\n\r\n\r\nThe more I look at the original spout the more I see a lot of good design/features in it, despite its complexity I would suggest you look at how it handles replay.\r\n\r\nThere is a manager that keeps track of what should/should not be replayed and when.\r\n\r\nThe current implementation is https://github.com/apache/storm/blob/master/external/storm-kafka/src/jvm/org/apache/storm/kafka/ExponentialBackoffMsgRetryManager.java\r\n\r\nFor it there is a pulggable interface, but it is not exposed to the end user.  Using that code when a new batch is fetch it will only replay tuples that have failed and have met the criteria to be replayed.  \r\n\r\nhttps://github.com/apache/storm/blob/master/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java#L231-L241\r\n\r\nA lot of that code could be reused almost with no changes at all.\r\n\r\n","created_at":"2016-03-17T14:54:50Z","updated_at":"2016-03-17T14:54:50Z","html_url":"https://github.com/apache/storm/pull/1131#discussion_r56517067","pull_request_url":"https://api.github.com/repos/apache/storm/pulls/1131","_links":{"self":{"href":"https://api.github.com/repos/apache/storm/pulls/comments/56517067"},"html":{"href":"https://github.com/apache/storm/pull/1131#discussion_r56517067"},"pull_request":{"href":"https://api.github.com/repos/apache/storm/pulls/1131"}}},"pull_request":{"url":"https://api.github.com/repos/apache/storm/pulls/1131","id":60106809,"html_url":"https://github.com/apache/storm/pull/1131","diff_url":"https://github.com/apache/storm/pull/1131.diff","patch_url":"https://github.com/apache/storm/pull/1131.patch","issue_url":"https://api.github.com/repos/apache/storm/issues/1131","number":1131,"state":"open","locked":false,"title":"STORM-822: Kafka Spout New Consumer API","user":{"login":"hmcl","id":10284328,"avatar_url":"https://avatars.githubusercontent.com/u/10284328?v=3","gravatar_id":"","url":"https://api.github.com/users/hmcl","html_url":"https://github.com/hmcl","followers_url":"https://api.github.com/users/hmcl/followers","following_url":"https://api.github.com/users/hmcl/following{/other_user}","gists_url":"https://api.github.com/users/hmcl/gists{/gist_id}","starred_url":"https://api.github.com/users/hmcl/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/hmcl/subscriptions","organizations_url":"https://api.github.com/users/hmcl/orgs","repos_url":"https://api.github.com/users/hmcl/repos","events_url":"https://api.github.com/users/hmcl/events{/privacy}","received_events_url":"https://api.github.com/users/hmcl/received_events","type":"User","site_admin":false},"body":"This patch is still under development and was uploaded at this moment for early testing. Please read README.\r\n\r\nThere may be a bug in the offsets management, because of diff o 1. I am looking into it. \r\nCurrently polling from an arbitrary offset is possible but it will come in the next patch, today or tomorrow\r\nI refactored the code a bit and left, maybe, some unnecessary locking. I am also looking into it.\r\n\r\n@connieyang @jianbzhou @tgravescs please let me know of any other requirements you may have and I will address them soon.\r\n\r\nThanks","created_at":"2016-02-21T22:18:37Z","updated_at":"2016-03-17T14:54:51Z","closed_at":null,"merged_at":null,"merge_commit_sha":"611887f25c35ee295522a6be397c67b672c4edcd","assignee":null,"milestone":null,"commits_url":"https://api.github.com/repos/apache/storm/pulls/1131/commits","review_comments_url":"https://api.github.com/repos/apache/storm/pulls/1131/comments","review_comment_url":"https://api.github.com/repos/apache/storm/pulls/comments{/number}","comments_url":"https://api.github.com/repos/apache/storm/issues/1131/comments","statuses_url":"https://api.github.com/repos/apache/storm/statuses/afc3bdebd70faac9da6af907c18665f47604a012","head":{"label":"hmcl:STORM-822","ref":"STORM-822","sha":"afc3bdebd70faac9da6af907c18665f47604a012","user":{"login":"hmcl","id":10284328,"avatar_url":"https://avatars.githubusercontent.com/u/10284328?v=3","gravatar_id":"","url":"https://api.github.com/users/hmcl","html_url":"https://github.com/hmcl","followers_url":"https://api.github.com/users/hmcl/followers","following_url":"https://api.github.com/users/hmcl/following{/other_user}","gists_url":"https://api.github.com/users/hmcl/gists{/gist_id}","starred_url":"https://api.github.com/users/hmcl/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/hmcl/subscriptions","organizations_url":"https://api.github.com/users/hmcl/orgs","repos_url":"https://api.github.com/users/hmcl/repos","events_url":"https://api.github.com/users/hmcl/events{/privacy}","received_events_url":"https://api.github.com/users/hmcl/received_events","type":"User","site_admin":false},"repo":{"id":37676775,"name":"storm-apache","full_name":"hmcl/storm-apache","owner":{"login":"hmcl","id":10284328,"avatar_url":"https://avatars.githubusercontent.com/u/10284328?v=3","gravatar_id":"","url":"https://api.github.com/users/hmcl","html_url":"https://github.com/hmcl","followers_url":"https://api.github.com/users/hmcl/followers","following_url":"https://api.github.com/users/hmcl/following{/other_user}","gists_url":"https://api.github.com/users/hmcl/gists{/gist_id}","starred_url":"https://api.github.com/users/hmcl/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/hmcl/subscriptions","organizations_url":"https://api.github.com/users/hmcl/orgs","repos_url":"https://api.github.com/users/hmcl/repos","events_url":"https://api.github.com/users/hmcl/events{/privacy}","received_events_url":"https://api.github.com/users/hmcl/received_events","type":"User","site_admin":false},"private":false,"html_url":"https://github.com/hmcl/storm-apache","description":"Mirror of Apache Storm","fork":true,"url":"https://api.github.com/repos/hmcl/storm-apache","forks_url":"https://api.github.com/repos/hmcl/storm-apache/forks","keys_url":"https://api.github.com/repos/hmcl/storm-apache/keys{/key_id}","collaborators_url":"https://api.github.com/repos/hmcl/storm-apache/collaborators{/collaborator}","teams_url":"https://api.github.com/repos/hmcl/storm-apache/teams","hooks_url":"https://api.github.com/repos/hmcl/storm-apache/hooks","issue_events_url":"https://api.github.com/repos/hmcl/storm-apache/issues/events{/number}","events_url":"https://api.github.com/repos/hmcl/storm-apache/events","assignees_url":"https://api.github.com/repos/hmcl/storm-apache/assignees{/user}","branches_url":"https://api.github.com/repos/hmcl/storm-apache/branches{/branch}","tags_url":"https://api.github.com/repos/hmcl/storm-apache/tags","blobs_url":"https://api.github.com/repos/hmcl/storm-apache/git/blobs{/sha}","git_tags_url":"https://api.github.com/repos/hmcl/storm-apache/git/tags{/sha}","git_refs_url":"https://api.github.com/repos/hmcl/storm-apache/git/refs{/sha}","trees_url":"https://api.github.com/repos/hmcl/storm-apache/git/trees{/sha}","statuses_url":"https://api.github.com/repos/hmcl/storm-apache/statuses/{sha}","languages_url":"https://api.github.com/repos/hmcl/storm-apache/languages","stargazers_url":"https://api.github.com/repos/hmcl/storm-apache/stargazers","contributors_url":"https://api.github.com/repos/hmcl/storm-apache/contributors","subscribers_url":"https://api.github.com/repos/hmcl/storm-apache/subscribers","subscription_url":"https://api.github.com/repos/hmcl/storm-apache/subscription","commits_url":"https://api.github.com/repos/hmcl/storm-apache/commits{/sha}","git_commits_url":"https://api.github.com/repos/hmcl/storm-apache/git/commits{/sha}","comments_url":"https://api.github.com/repos/hmcl/storm-apache/comments{/number}","issue_comment_url":"https://api.github.com/repos/hmcl/storm-apache/issues/comments{/number}","contents_url":"https://api.github.com/repos/hmcl/storm-apache/contents/{+path}","compare_url":"https://api.github.com/repos/hmcl/storm-apache/compare/{base}...{head}","merges_url":"https://api.github.com/repos/hmcl/storm-apache/merges","archive_url":"https://api.github.com/repos/hmcl/storm-apache/{archive_format}{/ref}","downloads_url":"https://api.github.com/repos/hmcl/storm-apache/downloads","issues_url":"https://api.github.com/repos/hmcl/storm-apache/issues{/number}","pulls_url":"https://api.github.com/repos/hmcl/storm-apache/pulls{/number}","milestones_url":"https://api.github.com/repos/hmcl/storm-apache/milestones{/number}","notifications_url":"https://api.github.com/repos/hmcl/storm-apache/notifications{?since,all,participating}","labels_url":"https://api.github.com/repos/hmcl/storm-apache/labels{/name}","releases_url":"https://api.github.com/repos/hmcl/storm-apache/releases{/id}","deployments_url":"https://api.github.com/repos/hmcl/storm-apache/deployments","created_at":"2015-06-18T18:19:49Z","updated_at":"2016-02-12T22:37:39Z","pushed_at":"2016-03-15T06:31:26Z","git_url":"git://github.com/hmcl/storm-apache.git","ssh_url":"git@github.com:hmcl/storm-apache.git","clone_url":"https://github.com/hmcl/storm-apache.git","svn_url":"https://github.com/hmcl/storm-apache","homepage":null,"size":28615,"stargazers_count":0,"watchers_count":0,"language":"Java","has_issues":false,"has_downloads":true,"has_wiki":false,"has_pages":true,"forks_count":0,"mirror_url":null,"open_issues_count":0,"forks":0,"open_issues":0,"watchers":0,"default_branch":"master"}},"base":{"label":"apache:master","ref":"master","sha":"1a0ed9a3764d35f4a756e597e330182606d64163","user":{"login":"apache","id":47359,"avatar_url":"https://avatars.githubusercontent.com/u/47359?v=3","gravatar_id":"","url":"https://api.github.com/users/apache","html_url":"https://github.com/apache","followers_url":"https://api.github.com/users/apache/followers","following_url":"https://api.github.com/users/apache/following{/other_user}","gists_url":"https://api.github.com/users/apache/gists{/gist_id}","starred_url":"https://api.github.com/users/apache/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/apache/subscriptions","organizations_url":"https://api.github.com/users/apache/orgs","repos_url":"https://api.github.com/users/apache/repos","events_url":"https://api.github.com/users/apache/events{/privacy}","received_events_url":"https://api.github.com/users/apache/received_events","type":"Organization","site_admin":false},"repo":{"id":14135470,"name":"storm","full_name":"apache/storm","owner":{"login":"apache","id":47359,"avatar_url":"https://avatars.githubusercontent.com/u/47359?v=3","gravatar_id":"","url":"https://api.github.com/users/apache","html_url":"https://github.com/apache","followers_url":"https://api.github.com/users/apache/followers","following_url":"https://api.github.com/users/apache/following{/other_user}","gists_url":"https://api.github.com/users/apache/gists{/gist_id}","starred_url":"https://api.github.com/users/apache/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/apache/subscriptions","organizations_url":"https://api.github.com/users/apache/orgs","repos_url":"https://api.github.com/users/apache/repos","events_url":"https://api.github.com/users/apache/events{/privacy}","received_events_url":"https://api.github.com/users/apache/received_events","type":"Organization","site_admin":false},"private":false,"html_url":"https://github.com/apache/storm","description":"Mirror of Apache Storm","fork":false,"url":"https://api.github.com/repos/apache/storm","forks_url":"https://api.github.com/repos/apache/storm/forks","keys_url":"https://api.github.com/repos/apache/storm/keys{/key_id}","collaborators_url":"https://api.github.com/repos/apache/storm/collaborators{/collaborator}","teams_url":"https://api.github.com/repos/apache/storm/teams","hooks_url":"https://api.github.com/repos/apache/storm/hooks","issue_events_url":"https://api.github.com/repos/apache/storm/issues/events{/number}","events_url":"https://api.github.com/repos/apache/storm/events","assignees_url":"https://api.github.com/repos/apache/storm/assignees{/user}","branches_url":"https://api.github.com/repos/apache/storm/branches{/branch}","tags_url":"https://api.github.com/repos/apache/storm/tags","blobs_url":"https://api.github.com/repos/apache/storm/git/blobs{/sha}","git_tags_url":"https://api.github.com/repos/apache/storm/git/tags{/sha}","git_refs_url":"https://api.github.com/repos/apache/storm/git/refs{/sha}","trees_url":"https://api.github.com/repos/apache/storm/git/trees{/sha}","statuses_url":"https://api.github.com/repos/apache/storm/statuses/{sha}","languages_url":"https://api.github.com/repos/apache/storm/languages","stargazers_url":"https://api.github.com/repos/apache/storm/stargazers","contributors_url":"https://api.github.com/repos/apache/storm/contributors","subscribers_url":"https://api.github.com/repos/apache/storm/subscribers","subscription_url":"https://api.github.com/repos/apache/storm/subscription","commits_url":"https://api.github.com/repos/apache/storm/commits{/sha}","git_commits_url":"https://api.github.com/repos/apache/storm/git/commits{/sha}","comments_url":"https://api.github.com/repos/apache/storm/comments{/number}","issue_comment_url":"https://api.github.com/repos/apache/storm/issues/comments{/number}","contents_url":"https://api.github.com/repos/apache/storm/contents/{+path}","compare_url":"https://api.github.com/repos/apache/storm/compare/{base}...{head}","merges_url":"https://api.github.com/repos/apache/storm/merges","archive_url":"https://api.github.com/repos/apache/storm/{archive_format}{/ref}","downloads_url":"https://api.github.com/repos/apache/storm/downloads","issues_url":"https://api.github.com/repos/apache/storm/issues{/number}","pulls_url":"https://api.github.com/repos/apache/storm/pulls{/number}","milestones_url":"https://api.github.com/repos/apache/storm/milestones{/number}","notifications_url":"https://api.github.com/repos/apache/storm/notifications{?since,all,participating}","labels_url":"https://api.github.com/repos/apache/storm/labels{/name}","releases_url":"https://api.github.com/repos/apache/storm/releases{/id}","deployments_url":"https://api.github.com/repos/apache/storm/deployments","created_at":"2013-11-05T08:00:14Z","updated_at":"2016-03-17T11:43:56Z","pushed_at":"2016-03-17T14:34:03Z","git_url":"git://github.com/apache/storm.git","ssh_url":"git@github.com:apache/storm.git","clone_url":"https://github.com/apache/storm.git","svn_url":"https://github.com/apache/storm","homepage":null,"size":162531,"stargazers_count":2955,"watchers_count":2955,"language":"Java","has_issues":false,"has_downloads":true,"has_wiki":false,"has_pages":true,"forks_count":2221,"mirror_url":"git://git.apache.org/storm.git","open_issues_count":96,"forks":2221,"open_issues":96,"watchers":2955,"default_branch":"master"}},"_links":{"self":{"href":"https://api.github.com/repos/apache/storm/pulls/1131"},"html":{"href":"https://github.com/apache/storm/pull/1131"},"issue":{"href":"https://api.github.com/repos/apache/storm/issues/1131"},"comments":{"href":"https://api.github.com/repos/apache/storm/issues/1131/comments"},"review_comments":{"href":"https://api.github.com/repos/apache/storm/pulls/1131/comments"},"review_comment":{"href":"https://api.github.com/repos/apache/storm/pulls/comments{/number}"},"commits":{"href":"https://api.github.com/repos/apache/storm/pulls/1131/commits"},"statuses":{"href":"https://api.github.com/repos/apache/storm/statuses/afc3bdebd70faac9da6af907c18665f47604a012"}}}}