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

Returns:

  • (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