lib/kafka/protocol.rb in ruby-kafka-0.7.3 vs lib/kafka/protocol.rb in ruby-kafka-0.7.4
- old
+ new
@@ -73,19 +73,24 @@
6 => NotLeaderForPartition,
7 => RequestTimedOut,
8 => BrokerNotAvailable,
9 => ReplicaNotAvailable,
10 => MessageSizeTooLarge,
+ 11 => StaleControllerEpoch,
12 => OffsetMetadataTooLarge,
+ 13 => NetworkException,
+ 14 => CoordinatorLoadInProgress,
15 => CoordinatorNotAvailable,
16 => NotCoordinatorForGroup,
17 => InvalidTopic,
18 => RecordListTooLarge,
19 => NotEnoughReplicas,
20 => NotEnoughReplicasAfterAppend,
21 => InvalidRequiredAcks,
22 => IllegalGeneration,
+ 23 => InconsistentGroupProtocol,
+ 24 => InvalidGroupId,
25 => UnknownMemberId,
26 => InvalidSessionTimeout,
27 => RebalanceInProgress,
28 => InvalidCommitOffsetSize,
29 => TopicAuthorizationFailed,
@@ -100,9 +105,11 @@
38 => InvalidReplicationFactor,
39 => InvalidReplicaAssignment,
40 => InvalidConfig,
41 => NotController,
42 => InvalidRequest,
+ 43 => UnsupportedForMessageFormat,
+ 44 => PolicyViolation,
45 => OutOfOrderSequenceNumberError,
46 => DuplicateSequenceNumberError,
47 => InvalidProducerEpochError,
48 => InvalidTxnStateError,
49 => InvalidProducerIDMappingError,