protocol.rb in ruby-kafka-0.3.18.beta1

- old
+ new

@@ -13,23 +13,24 @@
       10 => :group_coordinator,
       11 => :join_group,
       12 => :heartbeat,
       13 => :leave_group,
       14 => :sync_group,
+      17 => :sasl_handshake
     }
 
     ERRORS = {
       -1 => UnknownError,
-      1 => OffsetOutOfRange,
-      2 => CorruptMessage,
-      3 => UnknownTopicOrPartition,
-      4 => InvalidMessageSize,
-      5 => LeaderNotAvailable,
-      6 => NotLeaderForPartition,
-      7 => RequestTimedOut,
-      8 => BrokerNotAvailable,
-      9 => ReplicaNotAvailable,
+       1 => OffsetOutOfRange,
+       2 => CorruptMessage,
+       3 => UnknownTopicOrPartition,
+       4 => InvalidMessageSize,
+       5 => LeaderNotAvailable,
+       6 => NotLeaderForPartition,
+       7 => RequestTimedOut,
+       8 => BrokerNotAvailable,
+       9 => ReplicaNotAvailable,
       10 => MessageSizeTooLarge,
       12 => OffsetMetadataTooLarge,
       15 => GroupCoordinatorNotAvailable,
       16 => NotCoordinatorForGroup,
       17 => InvalidTopic,
@@ -39,10 +40,25 @@
       21 => InvalidRequiredAcks,
       22 => IllegalGeneration,
       25 => UnknownMemberId,
       26 => InvalidSessionTimeout,
       27 => RebalanceInProgress,
+      28 => InvalidCommitOffsetSize,
+      29 => TopicAuthorizationCode,
+      30 => GroupAuthorizationCode,
+      31 => ClusterAuthorizationCode,
+      32 => InvalidTimestamp,
+      33 => UnsupportedSaslMechanism,
+      34 => InvalidSaslState,
+      35 => UnsupportedVersion,
+      36 => TopicAlreadyExists,
+      37 => InvalidPartitions,
+      38 => InvalidReplicationFactor,
+      39 => InvalidReplicaAssignment,
+      40 => InvalidConfig,
+      41 => NotController,
+      42 => InvalidRequest
     }
 
     def self.handle_error(error_code)
       if error_code == 0
         # No errors, yay!
@@ -79,5 +95,7 @@
 require "kafka/protocol/heartbeat_response"
 require "kafka/protocol/offset_fetch_request"
 require "kafka/protocol/offset_fetch_response"
 require "kafka/protocol/offset_commit_request"
 require "kafka/protocol/offset_commit_response"
+require "kafka/protocol/sasl_handshake_request"
+require "kafka/protocol/sasl_handshake_response"