Class: KafkaSyrup::Protocol::MetadataRequest

Inherits:
Request
  • Object
show all
Defined in:
lib/kafka_syrup/protocol/metadata_request.rb

Instance Attribute Summary collapse

Attributes inherited from Request

#client_id, #correlation_id

Instance Method Summary collapse

Methods inherited from Request

#api_key, #api_version

Methods inherited from Base

#==, #config, #decode, #defaults

Methods included from Utils

#load_args, #log

Constructor Details

#initialize(*args) ⇒ MetadataRequest

Returns a new instance of MetadataRequest.



8
9
10
11
12
13
14
 
# File 'lib/kafka_syrup/protocol/metadata_request.rb', line 8

def initialize(*args)
  opts = args.last.is_a?(Hash) ? args.pop : {}

  load_args(opts)

  self.topics = args
end

Instance Attribute Details

#topics ⇒ Object

Returns the value of attribute topics.



6
7
8
 
# File 'lib/kafka_syrup/protocol/metadata_request.rb', line 6

def topics
  @topics
end

Instance Method Details

#encode ⇒ Object 



16
17
18
19
20
 
# File 'lib/kafka_syrup/protocol/metadata_request.rb', line 16

def encode
  super do
    E.write_array(topics, &E.method(:write_string))
  end
end