Backport https://github.com/zendesk/ruby-kafka/pull/901/files

sarcilav · sarcilav · commit c4cfe31b0ad9 · 2022-08-09T16:02:03.000+02:00
Refresh metadata if necessary on deliver_message zendesk#901
diff --git a/lib/kafka/client.rb b/lib/kafka/client.rb
@@ -164,6 +164,8 @@ def deliver_message(value, key: nil, topic:, partition: nil, partition_key: nil,
       attempt = 1
 
       begin
+        @cluster.refresh_metadata_if_necessary!
+
         operation.execute
 
         unless buffer.empty?
