Merge pull request #517 from fluent/revert-513-fix-close

Revert "Apply PR#468 patch only for 0.12.x."
fluent · Jul 31, 2024 · 27efbd0 · 27efbd0
2 parents d4e1964 + 1a37f2a
commit 27efbd0
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/lib/fluent/plugin/out_rdkafka2.rb b/lib/fluent/plugin/out_rdkafka2.rb
@@ -30,10 +30,7 @@ class Rdkafka::Producer
   def close(timeout = nil)
     rdkafka_version = Rdkafka::VERSION || '0.0.0'
     # Rdkafka version >= 0.12.0 changed its internals
-    # but reverted in >= 0.13.0
-    gem_version = Gem::Version::create(rdkafka_version)
-    if gem_version >= Gem::Version.create('0.12.0') and
-      gem_version <= Gem::Version.create('0.12.1')
+    if Gem::Version::create(rdkafka_version) >= Gem::Version.create('0.12.0')
       ObjectSpace.undefine_finalizer(self)
 
       return @client.close(timeout)