Merge pull request #88 from nasark/fetch_metadata_from_kafka

Fix Kafka Client List Topics Method
ManageIQ · May 3, 2024 · e7decd5 · e7decd5
2 parents 3f7db72 + 54bfcf3
commit e7decd5
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