重试策略

最近更新时间：2023-10-23 21:28:52

我的收藏

本页目录：

SCF 云函数重试策略
注意
短期重试指重试3次，总体重试时间不超过6小时。长期重试指6小时内，每间隔1分钟重试一次。
状态码
错误码
错误码描述
重试策略
400
BadRequest
无效请求
不重试
401
InvalidCredentials
无效凭据
不重试
403
ResourceUnavailable
资源不可用
短期重试
404
InvalidSubnetID
无效子网 ID
短期重试
406
RequestTooLarge
请求参数太大
不重试
429
BorrowContainerLimit
借容器超限
长期重试
430
UserFunctionExecError
用户代码报错
不重试
432
ResourceLimitReached
资源超过限制
长期重试
433
TimeLimitReached
用户函数执行超时
长期重试
435
FunctionNotFound
函数不存在
短期重试
434
MemoryLimitReached
用户函数内存超限
短期重试
436
InvalidParameterValue
无效参数
不重试
437
HandlerNotFount
指定的入口文件或函数不存在
短期重试
438
FunctionStatusError
函数状态错误
长期重试
439
UserProcExitError
用户函数进程执行中退出
短期重试
440
BorrowContainerDegradeError
借容器业务维度降级
短期重试
441
UnauthorizedOperation
用户 cam 鉴权不通过
短期重试
442
QualifierNotFound
函数版本不存在
短期重试
443
UserCodeError
函数函数解压失败
短期重试
450
UserResourceTimeOut
函数冷启动资源超时
长期重试
500
InternalError
内部错误
长期重试
532
ResourceExhausted
计算资源不足
长期重试
600
NodeAsyncInvokeReturn
异步请求
不重试
601
ContainerNotExists
异步请求指定的容器不存在
短期重试
CLS 重试策略
注意
短期重试指重试 3 次，每次间隔一分钟。长期重试指六小时内，每间隔一分钟重试一次。
状态码
错误码
描述
重试策略
400
InvalidAuthorization
签名串格式不合法
不重试
400
InvalidCompressType
指定的 x-cls-compress-type 不支持
不重试
400
InvalidContent
消息体错误，解压失败或者解析失败
不重试
400
InvalidContentType
指定的 Content-Type 不支持
不重试
400
InvalidParam
缺少必要参数或者个别参数不合法
不重试
400
MissingAgentIp
缺少 x-cls-agent-ip
不重试
400
MissingAgentVersion
缺少 x-cls-agent-version
不重试
400
MissingAuthorization
缺少 Authorization
不重试
400
MissingContent
消息体是空的
不重试
400
MissingContentType
缺少 Content-Type
不重试
400
TopicClosed
指定的日志主题已经关闭收集功能
短期重试
400
IndexRuleEmpty
指定的日志主题没有设置索引规则
短期重试
400
LogsetNotEmpty
指定的日志集非空，含有日志主题
短期重试
400
SyntaxError
检索语法错误
不重试
400
LogsetEmpty
指定的日志集为空，不包含任何日志主题
短期重试
400
LimitExceeded
并发查询超过限制
长期重试
400
InvalidParameterValue
云函数参数取值错误
不重试
400
MissingParameter
缺失部分云函数参数
不重试
400
UnknownParameter
未知的云函数参数
不重试
400
InvalidParameter
云函数参数错误
不重试
400
UnsupportedRegion
云函数不支持该地域
不重试
400
RequestLimitExceeded
云函数请求超过限制
长期重试
400
NoSuchVersion
云函数版本错误
不重试
400
ResourceNotFound
未找到相关云函数
短期重试
401
AuthFailure.SecretIdNotFound
密钥不存在。                
请在控制台检查密钥是否已被删除或者禁用，如状态正常，请检查密钥是否填写正确，注意前后不得有空格。
短期重试
401
AuthFailure.SignatureFailure
签名错误。 签名计算错误，请对照调用方式中的签名方法文档检查签名计算过程
不重试
401
AuthFailure.SignatureExpire
签名过期
不重试
401
AuthFailure.MFAFailure
MFA 错误
不重试
401
AuthFailure.UnauthorizedOperation
请求未授权。请参考 CAM 文档对鉴权的说明
短期重试
401
AuthFailure.InvalidSecretId
密钥非法（不是云 API 密钥类型）
不重试
401
AuthFailure.TokenFailure
token 错误
不重试
401
AuthFailure.Unauthorized
鉴权内部错误
短期重试
403
LogsetExceed
日志集数量超出限制，最多20个
短期重试
403
LogSizeExceed
提交的日志超出最大限制，最大5MB
不重试
403
MachineGroupExceed
机器组数量超出限制，最多200个
短期重试
403
NotAllowed
不允许此操作
不重试
403
TopicExceed
日志主题数量超出限制，最多10个
短期重试
403
ShipperExceed
投递规则数量超出限制，最多10个
短期重试
403
TaskReadOnly
只有失败的投递任务才能重启，其他状态时不能被修改
短期重试
403
AccountArrears
账户欠费
短期重试
403
ServiceNotActivated
日志服务未开通
短期重试
404
CursorNotExist
指定的位置没有可以下载的日志
短期重试
404
TaskNotExist
指定的投递任务不存在
短期重试
404
IndexNotExist
指定的索引规则不存在
短期重试
404
LogsetNotExist
指定的日志集不存在
短期重试
404
MachineGroupNotExist
指定的机器组不存在
短期重试
404
ShipperNotExist
指定的投递规则不存在
短期重试
404
TopicNotExist
指定的日志主题不存在
短期重试
404
ConsumerNotExist
指定的日志主题不存在消费任务
短期重试
404
DeliverFunctionNotExist
投递 SCF 任务不存在
短期重试
405
NotSupported
不支持此操作
不重试
409
IndexConflict
相同的索引规则已存在
短期重试
409
LogsetConflict
相同的日志集已存在
短期重试
409
MachineGroupConflict
相同的机器组已存在
短期重试
409
ShipperConflict
相同的投递规则已存在
短期重试
409
TopicConflict
相同的日志主题已存在
短期重试
409
ConsumerConflict
日志主题的消费任务已存在
短期重试
409
DeliverFunctionConflict
相同的投递 SCF 任务已经存在
短期重试
429
SpeedQuotaExceed
请求过于频繁
长期重试
500
InternalError
内部错误
长期重试
CKafka 重试策略
注意
短期重试指重试 3 次，每次间隔一分钟。长期重试指六小时内，每间隔一分钟重试一次。
错误码
CODE
重试策略
UNKNOWN_SERVER_ERROR
-1
短期重试
NONE
0
不重试
OFFSET_OUT_OF_RANGE
1
不重试
CORRUPT_MESSAGE
2
长期重试
UNKNOWN_TOPIC_OR_PARTITION
3
长期重试
INVALID_FETCH_SIZE
4
不重试
LEADER_NOT_AVAILABLE
5
长期重试
NOT_LEADER_OR_FOLLOWER
6
长期重试
REQUEST_TIMED_OUT
7
长期重试
BROKER_NOT_AVAILABLE
8
短期重试
REPLICA_NOT_AVAILABLE
9
长期重试
MESSAGE_TOO_LARGE
10
不重试
STALE_CONTROLLER_EPOCH
11
不重试
OFFSET_METADATA_TOO_LARGE
12
不重试
NETWORK_EXCEPTION
13
长期重试
COORDINATOR_LOAD_IN_PROGRESS
14
长期重试
COORDINATOR_NOT_AVAILABLE
15
长期重试
NOT_COORDINATOR
16
长期重试
INVALID_TOPIC_EXCEPTION
17
不重试
RECORD_LIST_TOO_LARGE
18
不重试
NOT_ENOUGH_REPLICAS
19
长期重试
NOT_ENOUGH_REPLICAS_AFTER_APPEND
20
长期重试
INVALID_REQUIRED_ACKS
21
不重试
ILLEGAL_GENERATION
22
不重试
INCONSISTENT_GROUP_PROTOCOL
23
不重试
INVALID_GROUP_ID
24
不重试
UNKNOWN_MEMBER_ID
25
不重试
INVALID_SESSION_TIMEOUT
26
不重试
REBALANCE_IN_PROGRESS
27
不重试
INVALID_COMMIT_OFFSET_SIZE
28
不重试
TOPIC_AUTHORIZATION_FAILED
29
不重试
GROUP_AUTHORIZATION_FAILED
30
不重试
CLUSTER_AUTHORIZATION_FAILED
31
不重试
INVALID_TIMESTAMP
32
不重试
UNSUPPORTED_SASL_MECHANISM
33
不重试
ILLEGAL_SASL_STATE
34
不重试
UNSUPPORTED_VERSION
35
不重试
TOPIC_ALREADY_EXISTS
36
不重试
INVALID_PARTITIONS
37
不重试
INVALID_REPLICATION_FACTOR
38
不重试
INVALID_REPLICA_ASSIGNMENT
39
不重试
INVALID_CONFIG
40
不重试
NOT_CONTROLLER
41
长期重试
INVALID_REQUEST
42
不重试
UNSUPPORTED_FOR_MESSAGE_FORMAT
43
不重试
POLICY_VIOLATION
44
不重试
OUT_OF_ORDER_SEQUENCE_NUMBER
45
不重试
DUPLICATE_SEQUENCE_NUMBER
46
不重试
INVALID_PRODUCER_EPOCH
47
不重试
INVALID_TXN_STATE
48
不重试
INVALID_PRODUCER_ID_MAPPING
49
不重试
INVALID_TRANSACTION_TIMEOUT
50
不重试
CONCURRENT_TRANSACTIONS
51
不重试
TRANSACTION_COORDINATOR_FENCED
52
不重试
TRANSACTIONAL_ID_AUTHORIZATION_FAILED
53
不重试
SECURITY_DISABLED
54
不重试
OPERATION_NOT_ATTEMPTED
55
不重试
KAFKA_STORAGE_ERROR
56
长期重试
LOG_DIR_NOT_FOUND
57
短期重试
SASL_AUTHENTICATION_FAILED
58
不重试
UNKNOWN_PRODUCER_ID
59
短期重试
REASSIGNMENT_IN_PROGRESS
60
短期重试
DELEGATION_TOKEN_AUTH_DISABLED
61
短期重试
DELEGATION_TOKEN_NOT_FOUND
62
不重试
DELEGATION_TOKEN_OWNER_MISMATCH
63
短期重试
DELEGATION_TOKEN_REQUEST_NOT_ALLOWED
64
不重试
DELEGATION_TOKEN_AUTHORIZATION_FAILED
65
短期重试
DELEGATION_TOKEN_EXPIRED
66
不重试
INVALID_PRINCIPAL_TYPE
67
不重试
NON_EMPTY_GROUP
68
短期重试
GROUP_ID_NOT_FOUND
69
不重试
FETCH_SESSION_ID_NOT_FOUND
70
长期重试
INVALID_FETCH_SESSION_EPOCH
71
长期重试
LISTENER_NOT_FOUND
72
长期重试
TOPIC_DELETION_DISABLED
73
短期重试
FENCED_LEADER_EPOCH
74
长期重试
UNKNOWN_LEADER_EPOCH
75
长期重试
UNSUPPORTED_COMPRESSION_TYPE
76
不重试
STALE_BROKER_EPOCH
77
不重试
OFFSET_NOT_AVAILABLE
78
长期重试
MEMBER_ID_REQUIRED
79
不重试
PREFERRED_LEADER_NOT_AVAILABLE
80
长期重试
GROUP_MAX_SIZE_REACHED
81
不重试
FENCED_INSTANCE_ID
82
不重试
ELIGIBLE_LEADERS_NOT_AVAILABLE
83
长期重试
ELECTION_NOT_NEEDED
84
长期重试
NO_REASSIGNMENT_IN_PROGRESS
85
不重试
GROUP_SUBSCRIBED_TO_TOPIC
86
不重试
INVALID_RECORD
87
不重试
UNSTABLE_OFFSET_COMMIT
88
长期重试
THROTTLING_QUOTA_EXCEEDED
89
长期重试
PRODUCER_FENCED
90
不重试
RESOURCE_NOT_FOUND
91
不重试
DUPLICATE_RESOURCE
92
不重试
UNACCEPTABLE_CREDENTIAL
93
不重试
INCONSISTENT_VOTER_SET
94
不重试
INVALID_UPDATE_VERSION
95
不重试
FEATURE_UPDATE_FAILED
96
不重试
PRINCIPAL_DESERIALIZATION_FAILURE
97
不重试
SNAPSHOT_NOT_FOUND
98
短期重试
POSITION_OUT_OF_RANGE
99
不重试
UNKNOWN_TOPIC_ID
100
长期重试
DUPLICATE_BROKER_REGISTRATION
101
短期重试
BROKER_ID_NOT_REGISTERED
102
短期重试
INCONSISTENT_TOPIC_ID
103
长期重试
INCONSISTENT_CLUSTER_ID
104
短期重试
TRANSACTIONAL_ID_NOT_FOUND
105
短期重试
FETCH_SESSION_TOPIC_ID_ERROR
106
长期重试
﻿

状态码	错误码	错误码描述	重试策略
400	BadRequest	无效请求	不重试
401	InvalidCredentials	无效凭据	不重试
403	ResourceUnavailable	资源不可用	短期重试
404	InvalidSubnetID	无效子网 ID	短期重试
406	RequestTooLarge	请求参数太大	不重试
429	BorrowContainerLimit	借容器超限	长期重试
430	UserFunctionExecError	用户代码报错	不重试
432	ResourceLimitReached	资源超过限制	长期重试
433	TimeLimitReached	用户函数执行超时	长期重试
435	FunctionNotFound	函数不存在	短期重试
434	MemoryLimitReached	用户函数内存超限	短期重试
436	InvalidParameterValue	无效参数	不重试
437	HandlerNotFount	指定的入口文件或函数不存在	短期重试
438	FunctionStatusError	函数状态错误	长期重试
439	UserProcExitError	用户函数进程执行中退出	短期重试
440	BorrowContainerDegradeError	借容器业务维度降级	短期重试
441	UnauthorizedOperation	用户 cam 鉴权不通过	短期重试
442	QualifierNotFound	函数版本不存在	短期重试
443	UserCodeError	函数函数解压失败	短期重试
450	UserResourceTimeOut	函数冷启动资源超时	长期重试
500	InternalError	内部错误	长期重试
532	ResourceExhausted	计算资源不足	长期重试
600	NodeAsyncInvokeReturn	异步请求	不重试
601	ContainerNotExists	异步请求指定的容器不存在	短期重试

状态码	错误码	描述	重试策略
400	InvalidAuthorization	签名串格式不合法	不重试
400	InvalidCompressType	指定的 x-cls-compress-type 不支持	不重试
400	InvalidContent	消息体错误，解压失败或者解析失败	不重试
400	InvalidContentType	指定的 Content-Type 不支持	不重试
400	InvalidParam	缺少必要参数或者个别参数不合法	不重试
400	MissingAgentIp	缺少 x-cls-agent-ip	不重试
400	MissingAgentVersion	缺少 x-cls-agent-version	不重试
400	MissingAuthorization	缺少 Authorization	不重试
400	MissingContent	消息体是空的	不重试
400	MissingContentType	缺少 Content-Type	不重试
400	TopicClosed	指定的日志主题已经关闭收集功能	短期重试
400	IndexRuleEmpty	指定的日志主题没有设置索引规则	短期重试
400	LogsetNotEmpty	指定的日志集非空，含有日志主题	短期重试
400	SyntaxError	检索语法错误	不重试
400	LogsetEmpty	指定的日志集为空，不包含任何日志主题	短期重试
400	LimitExceeded	并发查询超过限制	长期重试
400	InvalidParameterValue	云函数参数取值错误	不重试
400	MissingParameter	缺失部分云函数参数	不重试
400	UnknownParameter	未知的云函数参数	不重试
400	InvalidParameter	云函数参数错误	不重试
400	UnsupportedRegion	云函数不支持该地域	不重试
400	RequestLimitExceeded	云函数请求超过限制	长期重试
400	NoSuchVersion	云函数版本错误	不重试
400	ResourceNotFound	未找到相关云函数	短期重试
401	AuthFailure.SecretIdNotFound	密钥不存在。请在控制台检查密钥是否已被删除或者禁用，如状态正常，请检查密钥是否填写正确，注意前后不得有空格。	短期重试
401	AuthFailure.SignatureFailure	签名错误。签名计算错误，请对照调用方式中的签名方法文档检查签名计算过程	不重试
401	AuthFailure.SignatureExpire	签名过期	不重试
401	AuthFailure.MFAFailure	MFA 错误	不重试
401	AuthFailure.UnauthorizedOperation	请求未授权。请参考 CAM 文档对鉴权的说明	短期重试
401	AuthFailure.InvalidSecretId	密钥非法（不是云 API 密钥类型）	不重试
401	AuthFailure.TokenFailure	token 错误	不重试
401	AuthFailure.Unauthorized	鉴权内部错误	短期重试
403	LogsetExceed	日志集数量超出限制，最多20个	短期重试
403	LogSizeExceed	提交的日志超出最大限制，最大5MB	不重试
403	MachineGroupExceed	机器组数量超出限制，最多200个	短期重试
403	NotAllowed	不允许此操作	不重试
403	TopicExceed	日志主题数量超出限制，最多10个	短期重试
403	ShipperExceed	投递规则数量超出限制，最多10个	短期重试
403	TaskReadOnly	只有失败的投递任务才能重启，其他状态时不能被修改	短期重试
403	AccountArrears	账户欠费	短期重试
403	ServiceNotActivated	日志服务未开通	短期重试
404	CursorNotExist	指定的位置没有可以下载的日志	短期重试
404	TaskNotExist	指定的投递任务不存在	短期重试
404	IndexNotExist	指定的索引规则不存在	短期重试
404	LogsetNotExist	指定的日志集不存在	短期重试
404	MachineGroupNotExist	指定的机器组不存在	短期重试
404	ShipperNotExist	指定的投递规则不存在	短期重试
404	TopicNotExist	指定的日志主题不存在	短期重试
404	ConsumerNotExist	指定的日志主题不存在消费任务	短期重试
404	DeliverFunctionNotExist	投递 SCF 任务不存在	短期重试
405	NotSupported	不支持此操作	不重试
409	IndexConflict	相同的索引规则已存在	短期重试
409	LogsetConflict	相同的日志集已存在	短期重试
409	MachineGroupConflict	相同的机器组已存在	短期重试
409	ShipperConflict	相同的投递规则已存在	短期重试
409	TopicConflict	相同的日志主题已存在	短期重试
409	ConsumerConflict	日志主题的消费任务已存在	短期重试
409	DeliverFunctionConflict	相同的投递 SCF 任务已经存在	短期重试
429	SpeedQuotaExceed	请求过于频繁	长期重试
500	InternalError	内部错误	长期重试

错误码	CODE	重试策略
UNKNOWN_SERVER_ERROR	-1	短期重试
NONE	0	不重试
OFFSET_OUT_OF_RANGE	1	不重试
CORRUPT_MESSAGE	2	长期重试
UNKNOWN_TOPIC_OR_PARTITION	3	长期重试
INVALID_FETCH_SIZE	4	不重试
LEADER_NOT_AVAILABLE	5	长期重试
NOT_LEADER_OR_FOLLOWER	6	长期重试
REQUEST_TIMED_OUT	7	长期重试
BROKER_NOT_AVAILABLE	8	短期重试
REPLICA_NOT_AVAILABLE	9	长期重试
MESSAGE_TOO_LARGE	10	不重试
STALE_CONTROLLER_EPOCH	11	不重试
OFFSET_METADATA_TOO_LARGE	12	不重试
NETWORK_EXCEPTION	13	长期重试
COORDINATOR_LOAD_IN_PROGRESS	14	长期重试
COORDINATOR_NOT_AVAILABLE	15	长期重试
NOT_COORDINATOR	16	长期重试
INVALID_TOPIC_EXCEPTION	17	不重试
RECORD_LIST_TOO_LARGE	18	不重试
NOT_ENOUGH_REPLICAS	19	长期重试
NOT_ENOUGH_REPLICAS_AFTER_APPEND	20	长期重试
INVALID_REQUIRED_ACKS	21	不重试
ILLEGAL_GENERATION	22	不重试
INCONSISTENT_GROUP_PROTOCOL	23	不重试
INVALID_GROUP_ID	24	不重试
UNKNOWN_MEMBER_ID	25	不重试
INVALID_SESSION_TIMEOUT	26	不重试
REBALANCE_IN_PROGRESS	27	不重试
INVALID_COMMIT_OFFSET_SIZE	28	不重试
TOPIC_AUTHORIZATION_FAILED	29	不重试
GROUP_AUTHORIZATION_FAILED	30	不重试
CLUSTER_AUTHORIZATION_FAILED	31	不重试
INVALID_TIMESTAMP	32	不重试
UNSUPPORTED_SASL_MECHANISM	33	不重试
ILLEGAL_SASL_STATE	34	不重试
UNSUPPORTED_VERSION	35	不重试
TOPIC_ALREADY_EXISTS	36	不重试
INVALID_PARTITIONS	37	不重试
INVALID_REPLICATION_FACTOR	38	不重试
INVALID_REPLICA_ASSIGNMENT	39	不重试
INVALID_CONFIG	40	不重试
NOT_CONTROLLER	41	长期重试
INVALID_REQUEST	42	不重试
UNSUPPORTED_FOR_MESSAGE_FORMAT	43	不重试
POLICY_VIOLATION	44	不重试
OUT_OF_ORDER_SEQUENCE_NUMBER	45	不重试
DUPLICATE_SEQUENCE_NUMBER	46	不重试
INVALID_PRODUCER_EPOCH	47	不重试
INVALID_TXN_STATE	48	不重试
INVALID_PRODUCER_ID_MAPPING	49	不重试
INVALID_TRANSACTION_TIMEOUT	50	不重试
CONCURRENT_TRANSACTIONS	51	不重试
TRANSACTION_COORDINATOR_FENCED	52	不重试
TRANSACTIONAL_ID_AUTHORIZATION_FAILED	53	不重试
SECURITY_DISABLED	54	不重试
OPERATION_NOT_ATTEMPTED	55	不重试
KAFKA_STORAGE_ERROR	56	长期重试
LOG_DIR_NOT_FOUND	57	短期重试
SASL_AUTHENTICATION_FAILED	58	不重试
UNKNOWN_PRODUCER_ID	59	短期重试
REASSIGNMENT_IN_PROGRESS	60	短期重试
DELEGATION_TOKEN_AUTH_DISABLED	61	短期重试
DELEGATION_TOKEN_NOT_FOUND	62	不重试
DELEGATION_TOKEN_OWNER_MISMATCH	63	短期重试
DELEGATION_TOKEN_REQUEST_NOT_ALLOWED	64	不重试
DELEGATION_TOKEN_AUTHORIZATION_FAILED	65	短期重试
DELEGATION_TOKEN_EXPIRED	66	不重试
INVALID_PRINCIPAL_TYPE	67	不重试
NON_EMPTY_GROUP	68	短期重试
GROUP_ID_NOT_FOUND	69	不重试
FETCH_SESSION_ID_NOT_FOUND	70	长期重试
INVALID_FETCH_SESSION_EPOCH	71	长期重试
LISTENER_NOT_FOUND	72	长期重试
TOPIC_DELETION_DISABLED	73	短期重试
FENCED_LEADER_EPOCH	74	长期重试
UNKNOWN_LEADER_EPOCH	75	长期重试
UNSUPPORTED_COMPRESSION_TYPE	76	不重试
STALE_BROKER_EPOCH	77	不重试
OFFSET_NOT_AVAILABLE	78	长期重试
MEMBER_ID_REQUIRED	79	不重试
PREFERRED_LEADER_NOT_AVAILABLE	80	长期重试
GROUP_MAX_SIZE_REACHED	81	不重试
FENCED_INSTANCE_ID	82	不重试
ELIGIBLE_LEADERS_NOT_AVAILABLE	83	长期重试
ELECTION_NOT_NEEDED	84	长期重试
NO_REASSIGNMENT_IN_PROGRESS	85	不重试
GROUP_SUBSCRIBED_TO_TOPIC	86	不重试
INVALID_RECORD	87	不重试
UNSTABLE_OFFSET_COMMIT	88	长期重试
THROTTLING_QUOTA_EXCEEDED	89	长期重试
PRODUCER_FENCED	90	不重试
RESOURCE_NOT_FOUND	91	不重试
DUPLICATE_RESOURCE	92	不重试
UNACCEPTABLE_CREDENTIAL	93	不重试
INCONSISTENT_VOTER_SET	94	不重试
INVALID_UPDATE_VERSION	95	不重试
FEATURE_UPDATE_FAILED	96	不重试
PRINCIPAL_DESERIALIZATION_FAILURE	97	不重试
SNAPSHOT_NOT_FOUND	98	短期重试
POSITION_OUT_OF_RANGE	99	不重试
UNKNOWN_TOPIC_ID	100	长期重试
DUPLICATE_BROKER_REGISTRATION	101	短期重试
BROKER_ID_NOT_REGISTERED	102	短期重试
INCONSISTENT_TOPIC_ID	103	长期重试
INCONSISTENT_CLUSTER_ID	104	短期重试
TRANSACTIONAL_ID_NOT_FOUND	105	短期重试
FETCH_SESSION_TOPIC_ID_ERROR	106	长期重试