def bulk_write(self, metrics):
        """
        Write multiple metrics to kafka in one request

        Args:
            metrics (list):
        """
        try:
            for metric in metrics:
                self.producer.send(self.topic, metric)
            self.producer.flush()
        except (KafkaTimeoutError, NoBrokersAvailable) as exc:
            logger.warning('bulk_write metrics %r failure %r', metrics, exc)
def bulk_write ( self , metrics ) : try : for metric in metrics : self . producer . send ( self . topic , metric ) self . producer . flush ( ) except ( KafkaTimeoutError , NoBrokersAvailable ) as exc : logger . warning ( 'bulk_write metrics %r failure %r' , metrics , exc )
Write multiple metrics to kafka in one request

        Args:
            metrics (list):