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

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