protocol.rb in ruby-kafka-0.5.2.beta1

- old
+ new

@@ -69,13 +69,13 @@
       22 => IllegalGeneration,
       25 => UnknownMemberId,
       26 => InvalidSessionTimeout,
       27 => RebalanceInProgress,
       28 => InvalidCommitOffsetSize,
-      29 => TopicAuthorizationCode,
-      30 => GroupAuthorizationCode,
-      31 => ClusterAuthorizationCode,
+      29 => TopicAuthorizationFailed,
+      30 => GroupAuthorizationFailed,
+      31 => ClusterAuthorizationFailed,
       32 => InvalidTimestamp,
       33 => UnsupportedSaslMechanism,
       34 => InvalidSaslState,
       35 => UnsupportedVersion,
       36 => TopicAlreadyExists,
@@ -111,10 +111,10 @@
       APIS.fetch(api_key, :unknown)
     end
   end
 end
 
-require "kafka/protocol/topic_metadata_request"
+require "kafka/protocol/metadata_request"
 require "kafka/protocol/metadata_response"
 require "kafka/protocol/produce_request"
 require "kafka/protocol/produce_response"
 require "kafka/protocol/fetch_request"
 require "kafka/protocol/fetch_response"