lib/kafka/datadog.rb in ruby-kafka-1.1.0.beta1 vs lib/kafka/datadog.rb in ruby-kafka-1.1.0

@@ -29,11 +29,11 @@
   module Datadog
     STATSD_NAMESPACE = "ruby_kafka"
 
     class << self
       def statsd
-        @statsd ||= ::Datadog::Statsd.new(host, port, namespace: namespace, tags: tags)
+        @statsd ||= ::Datadog::Statsd.new(host, port, namespace: namespace, tags: tags, socket_path: socket_path)
       end
 
       def statsd=(statsd)
         clear
         @statsd = statsd
@@ -52,9 +52,18 @@
         @port
       end
 
       def port=(port)
         @port = port
+        clear
+      end
+
+      def socket_path
+        @socket_path
+      end
+
+      def socket_path=(socket_path)
+        @socket_path = socket_path
         clear
       end
 
       def namespace
         @namespace ||= STATSD_NAMESPACE