datadog.rb in ruby-kafka-0.3.16.beta1

- old
+ new

@@ -1,7 +1,7 @@
 begin
-  require "statsd"
+  require "datadog/statsd"
 rescue LoadError
   $stderr.puts "In order to report Kafka client metrics to Datadog you need to install the `dogstatsd-ruby` gem."
   raise
 end
 
@@ -26,11 +26,11 @@
   # metrics are automatically emitted.
   module Datadog
     STATSD_NAMESPACE = "ruby_kafka"
 
     def self.statsd
-      @statsd ||= Statsd.new(Statsd::DEFAULT_HOST, Statsd::DEFAULT_HOST, namespace: STATSD_NAMESPACE)
+      @statsd ||= ::Datadog::Statsd.new(::Datadog::Statsd::DEFAULT_HOST, ::Datadog::Statsd::DEFAULT_HOST, namespace: STATSD_NAMESPACE)
     end
 
     def self.host=(host)
       statsd.host = host
     end
@@ -39,9 +39,13 @@
       statsd.port = port
     end
 
     def self.namespace=(namespace)
       statsd.namespace = namespace
+    end
+
+    def self.tags=(tags)
+      statsd.tags = tags
     end
 
     class StatsdSubscriber < ActiveSupport::Subscriber
       private
 