class Kafka::Statsd::AsyncProducerSubscriber

def buffer_overflow(event)
  client = event.payload.fetch(:client_id)
  topic = event.payload.fetch(:topic)
  increment("async_producer.#{client}.#{topic}.produce.errors")
end