Skip to content

Commit 0d1a945

Browse files
committed
Refresh metadata if necessary on deliver_message zendesk#901
1 parent 29ddee2 commit 0d1a945

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

lib/kafka/client.rb

+2
Original file line numberDiff line numberDiff line change
@@ -164,6 +164,8 @@ def deliver_message(value, key: nil, topic:, partition: nil, partition_key: nil,
164164
attempt = 1
165165

166166
begin
167+
@cluster.refresh_metadata_if_necessary!
168+
167169
operation.execute
168170

169171
unless buffer.empty?

0 commit comments

Comments
 (0)