The current implementation of the async publication of docs from server resources to Kafka uses a communication channel of a fixed length (as a sliding buffer) and a collection of Kafka producers.
Provide monitoring and alerting on the health of Kafka producers and the length of the comm channel.