We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
Gem::Version
1 parent b223101 commit 95b58ebCopy full SHA for 95b58eb
lib/fluent/plugin/out_rdkafka2.rb
@@ -30,7 +30,7 @@ class Rdkafka::Producer
30
def close(timeout = nil)
31
rdkafka_version = Rdkafka::VERSION || '0.0.0'
32
# Rdkafka version >= 0.12.0 changed its internals
33
- if rdkafka_version.split('.')[1].to_i >= 12
+ if Gem::Version::create(rdkafka_version) >= Gem::Version.create('0.12.0')
34
ObjectSpace.undefine_finalizer(self)
35
36
return @client.close(timeout)
0 commit comments