Repository: kafka Updated Branches: refs/heads/0.10.2 b676f51dd -> 90b9a8a3c
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 (cherry picked from commit 3bb0d3cd888c29a002400253d9ff84ce73ebc03c) Signed-off-by: Ismael Juma <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/90b9a8a3 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/90b9a8a3 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/90b9a8a3 Branch: refs/heads/0.10.2 Commit: 90b9a8a3cc7f9443101f9f95c0acc87873453f68 Parents: b676f51 Author: Dana Powers <[email protected]> Authored: Tue Jan 24 12:41:21 2017 +0000 Committer: Ismael Juma <[email protected]> Committed: Tue Jan 24 12:45:10 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/90b9a8a3/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";
