retrieve kafka metadata method

nasark · May 3, 2024 · 54bfcf3 · 54bfcf3
1 parent 3f7db72
commit 54bfcf3
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/lib/manageiq/messaging/kafka/client.rb b/lib/manageiq/messaging/kafka/client.rb
@@ -65,8 +65,7 @@ def close
 
         # list all topics
         def topics
-          native_kafka = producer.instance_variable_get(:@native_kafka)
-          Rdkafka::Metadata.new(native_kafka).topics.collect { |topic| topic[:topic_name] }
+          kafka_client.admin.metadata.topics.map { |topic| topic[:topic_name] }
         end
 
         private