Refresh metadata if necessary on deliver_message

wamaral · wamaral · commit 456807491159 · 2021-05-03T18:01:48.000+02:00
diff --git a/lib/kafka/client.rb b/lib/kafka/client.rb
@@ -210,6 +210,8 @@ def deliver_message(value, key: nil, headers: {}, topic:, partition: nil, partit
       attempt = 1
 
       begin
+        @cluster.refresh_metadata_if_necessary!
+
         operation.execute
 
         unless buffer.empty?
