You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2017/01/24 12:45:04 UTC
kafka git commit: MINOR: Add expected Error Codes to ProduceResponse
documentation
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 <da...@gmail.com>
Reviewers: Grant Henke <gr...@gmail.com>, Ismael Juma <is...@juma.me.uk>
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 <da...@gmail.com>
Authored: Tue Jan 24 12:41:21 2017 +0000
Committer: Ismael Juma <is...@juma.me.uk>
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";