Sha256: 089b5661d789e3189b22c4608db583a462978adb44b533b6cf65fa1b1b29e130
Contents?: true
Size: 587 Bytes
Versions: 49
Compression:
Stored size: 587 Bytes
Contents
# frozen_string_literal: true
module Kafka
module Protocol
class DeleteTopicsRequest
def initialize(topics:, timeout:)
@topics, @timeout = topics, timeout
end
def api_key
DELETE_TOPICS_API
end
def api_version
0
end
def response_class
Protocol::DeleteTopicsResponse
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
end
end
end
Version data entries
49 entries across 49 versions & 4 rubygems