Fixed a metrics issue where messages sent to Kafka would count as failed even when they were successfully sent late due to its internal buffering.