修复一些可能导致错误桥接指标的问题。 修复当Kafka或其连接中断时，可能导致Kafka Producer桥的消息丢失和错误指标的问题。 修复一些问题，这些问题可能导致在为桥接使用批处理时，同一消息被多次传递，以及批处理被重试时。