浏览代码

Add KError = 9

According official page, 9 is unused:
http://search.cpan.org/~sgladkov/Kafka/lib/Kafka.pm

But I met lots of "Unknown error, how did this happen? Error code = 9"
So I Found out:
http://search.cpan.org/~sgladkov/Kafka/lib/Kafka.pm

I think the official page is not up to date.
Liu Cong 11 年之前
父节点
当前提交
17576f1e6d
共有 1 个文件被更改,包括 3 次插入0 次删除
  1. 3 0
      errors.go

+ 3 - 0
errors.go

@@ -89,6 +89,7 @@ const (
 	NotLeaderForPartition           KError = 6
 	NotLeaderForPartition           KError = 6
 	RequestTimedOut                 KError = 7
 	RequestTimedOut                 KError = 7
 	BrokerNotAvailable              KError = 8
 	BrokerNotAvailable              KError = 8
+	ReplicaNotAvailable             KError = 9
 	MessageSizeTooLarge             KError = 10
 	MessageSizeTooLarge             KError = 10
 	StaleControllerEpochCode        KError = 11
 	StaleControllerEpochCode        KError = 11
 	OffsetMetadataTooLarge          KError = 12
 	OffsetMetadataTooLarge          KError = 12
@@ -121,6 +122,8 @@ func (err KError) Error() string {
 		return "kafka server: Request exceeded the user-specified time limit in the request."
 		return "kafka server: Request exceeded the user-specified time limit in the request."
 	case BrokerNotAvailable:
 	case BrokerNotAvailable:
 		return "kafka server: Broker not available. Not a client facing error, we should never receive this!!!"
 		return "kafka server: Broker not available. Not a client facing error, we should never receive this!!!"
+	case ReplicaNotAvailable:
+		return "kafka server: Replica not available."
 	case MessageSizeTooLarge:
 	case MessageSizeTooLarge:
 		return "kafka server: Message was too large, server rejected it to avoid allocation error."
 		return "kafka server: Message was too large, server rejected it to avoid allocation error."
 	case StaleControllerEpochCode:
 	case StaleControllerEpochCode: