class Kafka::Datadog::AsyncProducerSubscriber

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