feat: Add Kafka.version_info and Kafka.librdkafka_version methods

BT-OpenSource · Dec 18, 2024 · 9bbd286 · 9bbd286
1 parent 09d67c8
commit 9bbd286
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,6 +1,9 @@
 # Changelog
 
 ## [Unreleased]
+### Added
+- Add `Kafka.version_info` and `Kafka.librdkafka_version` methods.
+
 ### Changed
 - Update `Kafka::Consumer#poll` and `Kafka::Consumer#each` to automatically raise a `Kafka::ConsumerException` if the
   message is an error. Pass `raise_on_error: false` to maintain the previous behaviour.

diff --git a/src/crafka.cr b/src/crafka.cr
@@ -6,6 +6,14 @@ module Kafka
 
   Log = ::Log.for("crafka")
 
+  def self.version_info
+    "crafka v#{VERSION}, librdkafka v#{librdkafka_version}"
+  end
+
+  def self.librdkafka_version
+    String.new(LibRdKafka.version_str)
+  end
+
   class KafkaException < Exception
     def initialize(@err : Int32 | String); end