class Kafka::Protocol::DeleteTopicsRequest
def encode(encoder)
def encode(encoder) encoder.write_array(@topics) do |topic| encoder.write_string(topic) end # Timeout is in ms. encoder.write_int32(@timeout * 1000) end
def encode(encoder) encoder.write_array(@topics) do |topic| encoder.write_string(topic) end # Timeout is in ms. encoder.write_int32(@timeout * 1000) end