lib/rdkafka/admin/delete_topic_handle.rb in karafka-rdkafka-0.13.5 vs lib/rdkafka/admin/delete_topic_handle.rb in karafka-rdkafka-0.13.6

@@ -17,12 +17,15 @@
       def create_result
         DeleteTopicReport.new(self[:error_string], self[:result_name])
       end
 
       def raise_error
-        raise RdkafkaError.new(
-            self[:response],
-            broker_message: DeleteTopicReport.new(self[:error_string], self[:result_name]).error_string
+        RdkafkaError.validate!(
+          self[:response],
+          broker_message: DeleteTopicReport.new(
+            self[:error_string],
+            self[:result_name]
+          ).error_string
         )
       end
     end
   end
 end