Skip to content

Commit 7632311

Browse files
authored
Added new Error code UNKNOWN_TOPIC_ID (#4525)
1 parent 42cc318 commit 7632311

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

src/rdkafka.c

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -700,6 +700,7 @@ static const struct rd_kafka_err_desc rd_kafka_err_descs[] = {
700700
_ERR_DESC(RD_KAFKA_RESP_ERR_PRINCIPAL_DESERIALIZATION_FAILURE,
701701
"Broker: Request principal deserialization failed during "
702702
"forwarding"),
703+
_ERR_DESC(RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_ID, "Broker: Unknown topic id"),
703704
_ERR_DESC(RD_KAFKA_RESP_ERR_FENCED_MEMBER_EPOCH,
704705
"Broker: The member epoch is fenced by the group coordinator"),
705706
_ERR_DESC(RD_KAFKA_RESP_ERR_STALE_MEMBER_EPOCH,

src/rdkafka.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -631,6 +631,8 @@ typedef enum {
631631
RD_KAFKA_RESP_ERR_FEATURE_UPDATE_FAILED = 96,
632632
/** Request principal deserialization failed during forwarding */
633633
RD_KAFKA_RESP_ERR_PRINCIPAL_DESERIALIZATION_FAILURE = 97,
634+
/** Unknown Topic Id */
635+
RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_ID = 100,
634636
/** The member epoch is fenced by the group coordinator */
635637
RD_KAFKA_RESP_ERR_FENCED_MEMBER_EPOCH = 110,
636638
/** The member epoch is stale */

0 commit comments

Comments
 (0)