retrieve kafka metadata method

nasark · May 2, 2024 · 7d9446d · 7d9446d
1 parent 3f7db72
commit 7d9446d
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/lib/manageiq/messaging/kafka/client.rb b/lib/manageiq/messaging/kafka/client.rb
@@ -69,6 +69,11 @@ def topics
           Rdkafka::Metadata.new(native_kafka).topics.collect { |topic| topic[:topic_name] }
         end
 
+        def metadata
+          native_kafka = producer.instance_variable_get(:@native_kafka)
+          Rdkafka::Admin.new(native_kafka).metadata
+        end
+
         private
 
         attr_reader :kafka_client