close kafka admin client connection

ManageIQ · May 3, 2024 · 3619ba3 · 3619ba3
1 parent 0fd700a
commit 3619ba3
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/lib/manageiq/messaging/kafka/client.rb b/lib/manageiq/messaging/kafka/client.rb
@@ -56,6 +56,9 @@ def ack(ack_ref)
         end
 
         def close
+          @admin&.close
+          @admin = nil
+
           @producer&.close
           @producer = nil
 

diff --git a/lib/manageiq/messaging/kafka/common.rb b/lib/manageiq/messaging/kafka/common.rb
@@ -8,6 +8,10 @@ module Common
 
         private
 
+        def admin
+          @admin ||= kafka_client.admin
+        end
+
         def producer
           @producer ||= kafka_client.producer
         end