Repository: kafka Updated Branches: refs/heads/trunk 567180605 -> 3bb0d3cd8
MINOR: Add expected Error Codes to ProduceResponse documentation This is a documentation-only patch discussed on the mailing list. The intent is to have these changes propagated to the protocol wiki (https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol) . Author: Dana Powers <[email protected]> Reviewers: Grant Henke <[email protected]>, Ismael Juma <[email protected]> Closes #918 from dpkp/produce_response_errors Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/3bb0d3cd Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/3bb0d3cd Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/3bb0d3cd Branch: refs/heads/trunk Commit: 3bb0d3cd888c29a002400253d9ff84ce73ebc03c Parents: 5671806 Author: Dana Powers <[email protected]> Authored: Tue Jan 24 12:41:21 2017 +0000 Committer: Ismael Juma <[email protected]> Committed: Tue Jan 24 12:44:17 2017 +0000 ---------------------------------------------------------------------- .../apache/kafka/common/requests/ProduceResponse.java | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/3bb0d3cd/clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java ---------------------------------------------------------------------- diff --git a/clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java b/clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java index 71e6ab5..6c2125a 100644 --- a/clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java +++ b/clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java @@ -48,7 +48,16 @@ public class ProduceResponse extends AbstractResponse { /** * Possible error code: * - * TODO + * CORRUPT_MESSAGE (2) + * UNKNOWN_TOPIC_OR_PARTITION (3) + * NOT_LEADER_FOR_PARTITION (6) + * MESSAGE_TOO_LARGE (10) + * INVALID_TOPIC (17) + * RECORD_LIST_TOO_LARGE (18) + * NOT_ENOUGH_REPLICAS (19) + * NOT_ENOUGH_REPLICAS_AFTER_APPEND (20) + * INVALID_REQUIRED_ACKS (21) + * TOPIC_AUTHORIZATION_FAILED (29) */ private static final String BASE_OFFSET_KEY_NAME = "base_offset";
