@@ -327,6 +327,11 @@ enum ErrorCode {
327
327
ERR__AUTO_OFFSET_RESET = -140 ,
328
328
/* * Partition log truncation detected */
329
329
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 ,
330
335
331
336
/* * End internal error codes */
332
337
ERR__END = -100 ,
@@ -544,7 +549,28 @@ enum ErrorCode {
544
549
/* * Unable to update finalized features due to server error */
545
550
ERR_FEATURE_UPDATE_FAILED = 96 ,
546
551
/* * 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
548
574
};
549
575
550
576
0 commit comments