class Kafka::Datadog::StatsdSubscriber

def emit(type, *args, tags: {})
  tags = tags.map {|k, v| "#{k}:#{v}" }.to_a
  Kafka::Datadog.statsd.send(type, *args, tags: tags)
end