lib/kafka/connection.rb in ruby-kafka-0.1.7 vs lib/kafka/connection.rb in ruby-kafka-0.2.0

@@ -124,9 +124,10 @@
     def write_request(request, notification)
       @logger.debug "Sending request #{@correlation_id} to #{to_s}"
 
       message = Kafka::Protocol::RequestMessage.new(
         api_key: request.api_key,
+        api_version: request.respond_to?(:api_version) ? request.api_version : 0,
         correlation_id: @correlation_id,
         client_id: @client_id,
         request: request,
       )