module Kafka::Statsd

def self.host=(host)
  statsd.host = host
  statsd.connect if statsd.respond_to?(:connect)
end

def self.namespace=(namespace)
  statsd.namespace = namespace
end

def self.port=(port)
  statsd.port = port
  statsd.connect if statsd.respond_to?(:connect)
end

def self.statsd
  @statsd ||= ::Statsd.new(DEFAULT_HOST, DEFAULT_PORT).tap { |sd| sd.namespace = DEFAULT_NAMESPACE }
end