@@ -327,6 +327,11 @@ enum ErrorCode {
327327 ERR__AUTO_OFFSET_RESET = -140 ,
328328 /* * Partition log truncation detected */
329329 ERR__LOG_TRUNCATION = -139 ,
330+ /* * A different record in the batch was invalid
331+ * and this message failed persisting. */
332+ ERR__INVALID_DIFFERENT_RECORD = -138 ,
333+ /* * Broker is going away but client isn't terminating */
334+ ERR__DESTROY_BROKER = -137 ,
330335
331336 /* * End internal error codes */
332337 ERR__END = -100 ,
@@ -544,7 +549,28 @@ enum ErrorCode {
544549 /* * Unable to update finalized features due to server error */
545550 ERR_FEATURE_UPDATE_FAILED = 96 ,
546551 /* * Request principal deserialization failed during forwarding */
547- ERR_PRINCIPAL_DESERIALIZATION_FAILURE = 97
552+ ERR_PRINCIPAL_DESERIALIZATION_FAILURE = 97 ,
553+ /* * Unknown Topic Id */
554+ ERR_UNKNOWN_TOPIC_ID = 100 ,
555+ /* * The member epoch is fenced by the group coordinator */
556+ ERR_FENCED_MEMBER_EPOCH = 110 ,
557+ /* * The instance ID is still used by another member in the
558+ * consumer group */
559+ ERR_UNRELEASED_INSTANCE_ID = 111 ,
560+ /* * The assignor or its version range is not supported by the consumer
561+ * group */
562+ ERR_UNSUPPORTED_ASSIGNOR = 112 ,
563+ /* * The member epoch is stale */
564+ ERR_STALE_MEMBER_EPOCH = 113 ,
565+ /* * Client sent a push telemetry request with an invalid or outdated
566+ * subscription ID. */
567+ ERR_UNKNOWN_SUBSCRIPTION_ID = 117 ,
568+ /* * Client sent a push telemetry request larger than the maximum size
569+ * the broker will accept. */
570+ ERR_TELEMETRY_TOO_LARGE = 118 ,
571+ /* * Client metadata is stale,
572+ * client should rebootstrap to obtain new metadata. */
573+ ERR_REBOOTSTRAP_REQUIRED = 129
548574};
549575
550576
0 commit comments