Update error response codes

(cherry picked from commit 9b3fce7)

Author: benesch

src-cpp/rdkafkacpp.h

@@ -428,8 +428,22 @@ enum ErrorCode {
         ERR_LISTENER_NOT_FOUND = 72,
         /** Topic deletion is disabled */
         ERR_TOPIC_DELETION_DISABLED = 73,
+        /** Leader epoch is older than broker epoch */
+        ERR_FENCED_LEADER_EPOCH = 74,
+        /** Leader epoch is newer than broker epoch */
+        ERR_UNKNOWN_LEADER_EPOCH = 75,
         /** Unsupported compression type */
-        ERR_UNSUPPORTED_COMPRESSION_TYPE = 74
+        ERR_UNSUPPORTED_COMPRESSION_TYPE = 76,
+        /** Broker epoch has changed */
+        ERR_STALE_BROKER_EPOCH = 77,
+        /** Leader high watermark is not caught up */
+        ERR_OFFSET_NOT_AVAILABLE = 78,
+        /** Group member needs a valid member ID */
+        ERR_MEMBER_ID_REQUIRED = 79,
+        /** Preferred leader was not available */
+        ERR_PREFERRED_LEADER_NOT_AVAILABLE = 80,
+        /** Consumer group has reached maximum size */
+        ERR_GROUP_MAX_SIZE_REACHED = 81,
 };
 
 

src/rdkafka.c

@@ -594,8 +594,22 @@ static const struct rd_kafka_err_desc rd_kafka_err_descs[] = {
                   "No matching listener"),
         _ERR_DESC(RD_KAFKA_RESP_ERR_TOPIC_DELETION_DISABLED,
                   "Topic deletion is disabled"),
+        _ERR_DESC(RD_KAFKA_RESP_ERR_FENCED_LEADER_EPOCH,
+                  "Leader epoch is older than broker epoch"),
+        _ERR_DESC(RD_KAFKA_RESP_ERR_UNKNOWN_LEADER_EPOCH,
+                  "Leader epoch is newer than broker epoch"),
         _ERR_DESC(RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE,
                   "Unsupported compression type"),
+        _ERR_DESC(RD_KAFKA_RESP_ERR_STALE_BROKER_EPOCH,
+                  "Broker epoch has changed"),
+        _ERR_DESC(RD_KAFKA_RESP_ERR_OFFSET_NOT_AVAILABLE,
+                  "Leader high watermark is not caught up"),
+        _ERR_DESC(RD_KAFKA_RESP_ERR_MEMBER_ID_REQUIRED,
+                  "Group member needs a valid member ID"),
+        _ERR_DESC(RD_KAFKA_RESP_ERR_PREFERRED_LEADER_NOT_AVAILABLE,
+                  "Preferred leader was not available"),
+        _ERR_DESC(RD_KAFKA_RESP_ERR_GROUP_MAX_SIZE_REACHED,
+                  "Consumer group has reached maximum size"),
 
 	_ERR_DESC(RD_KAFKA_RESP_ERR__END, NULL)
 };

src/rdkafka.h

@@ -521,8 +521,22 @@ typedef enum {
         RD_KAFKA_RESP_ERR_LISTENER_NOT_FOUND = 72,
         /** Topic deletion is disabled */
         RD_KAFKA_RESP_ERR_TOPIC_DELETION_DISABLED = 73,
+        /** Leader epoch is older than broker epoch */
+        RD_KAFKA_RESP_ERR_FENCED_LEADER_EPOCH = 74,
+        /** Leader epoch is newer than broker epoch */
+        RD_KAFKA_RESP_ERR_UNKNOWN_LEADER_EPOCH = 75,
         /** Unsupported compression type */
-        RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE = 74,
+        RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE = 76,
+        /** Broker epoch has changed */
+        RD_KAFKA_RESP_ERR_STALE_BROKER_EPOCH = 77,
+        /** Leader high watermark is not caught up */
+        RD_KAFKA_RESP_ERR_OFFSET_NOT_AVAILABLE = 78,
+        /** Group member needs a valid member ID */
+        RD_KAFKA_RESP_ERR_MEMBER_ID_REQUIRED = 79,
+        /** Preferred leader was not available */
+        RD_KAFKA_RESP_ERR_PREFERRED_LEADER_NOT_AVAILABLE = 80,
+        /** Consumer group has reached maximum size */
+        RD_KAFKA_RESP_ERR_GROUP_MAX_SIZE_REACHED = 81,
 
         RD_KAFKA_RESP_ERR_END_ALL,
 } rd_kafka_resp_err_t;