Sha256: 657e38ae006b410b04fd9eed5feec2ae834512952a344744cc5b09a2e64e6406
Contents?: true
Size: 556 Bytes
Versions: 8
Compression:
Stored size: 556 Bytes
Contents
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
8 entries across 8 versions & 1 rubygems