Sha256: 72e543af2778653d5a804af2bdabc9fead883d3d4d3e8667589e77abcab58f5b
Contents?: true
Size: 779 Bytes
Versions: 43
Compression:
Stored size: 779 Bytes
Contents
# frozen_string_literal: true
module Rdkafka
class Admin
class CreateTopicHandle < AbstractHandle
layout :pending, :bool,
:response, :int,
:error_string, :pointer,
:result_name, :pointer
# @return [String] the name of the operation
def operation_name
"create topic"
end
# @return [Boolean] whether the create topic was successful
def create_result
CreateTopicReport.new(self[:error_string], self[:result_name])
end
def raise_error
RdkafkaError.validate!(
self[:response],
broker_message: CreateTopicReport.new(
self[:error_string],
self[:result_name]
).error_string
)
end
end
end
end
Version data entries
43 entries across 43 versions & 1 rubygems