Skip to content

Commit a0fac67

Browse files
committed
Make aws signer lib dependent on min ruby version
1 parent 3d63b3f commit a0fac67

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

fluent-plugin-kafka.gemspec

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,9 @@ Gem::Specification.new do |gem|
2222

2323
if ENV['USE_RDKAFKA']
2424
gem.add_dependency 'rdkafka', [ENV['RDKAFKA_VERSION_MIN_RANGE'], ENV['RDKAFKA_VERSION_MAX_RANGE']]
25-
gem.add_dependency 'aws-msk-iam-sasl-signer', '~> 0.1.1'
25+
if Gem::Version.new('3.0' >= Gem::Version.new(RUBY_VERSION)
26+
gem.add_dependency 'aws-msk-iam-sasl-signer', '~> 0.1.1'
27+
end
2628
end
2729

2830
gem.add_development_dependency "rake", ">= 0.9.2"

lib/fluent/plugin/out_rdkafka2.rb

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,11 +16,14 @@
1616
elsif rdkafka_version >= Gem::Version.create('0.16.0')
1717
require_relative 'rdkafka_patch/0_16_0'
1818
end
19-
require 'aws_msk_iam_sasl_signer' if rdkafka_version >= Gem::Version.create('0.16.0')
2019
rescue LoadError, NameError
2120
raise "unable to patch rdkafka."
2221
end
2322

23+
if Gem::Version.create(RUBY_VERSION) >= Gem::Version.create('3.0')
24+
require 'aws-msk-iam-sasl-signer'
25+
end
26+
2427
module Fluent::Plugin
2528
class Fluent::Rdkafka2Output < Output
2629
Fluent::Plugin.register_output('rdkafka2', self)

0 commit comments

Comments
 (0)