Module: TingYun::Instrumentation::Kafka
- Defined in:
- lib/ting_yun/instrumentation/kafka.rb
Constant Summary collapse
- KAFKA_MIN_VERSION =
'0.2.0'.freeze
- KAFKA_MAX_VERSION =
'0.3.16'.freeze
- UNKNOWN =
'Unknown:Unknown'.freeze
Class Method Summary collapse
Class Method Details
.version_support? ⇒ Boolean
9 10 11 12 13 14 15 16 17 |
# File 'lib/ting_yun/instrumentation/kafka.rb', line 9 def self.version_support? if defined? RUBY_VERSION kafka_version = TingYun::Support::VersionNumber.new(Kafka::VERSION) kafka_version >= TingYun::Support::VersionNumber.new(KAFKA_MIN_VERSION) && kafka_version <= TingYun::Support::VersionNumber.new(KAFKA_MAX_VERSION) else false end end |