def METHOD_NAME(self) -> None:
    timeout = 0.0
    if len(self.__producer) >= self.__producer_queue_max_size:
        metrics.incr("simple_produce_step.producer_queue_backup", amount=len(self.__producer))
        timeout = self.__producer_long_poll_timeout
    self.poll_producer(timeout)
    with metrics.timer("simple_produce_step.poll.maybe_commit", sample_rate=0.05):
        self.__commit_function(self.__produced_message_offsets)
        self.__produced_message_offsets = {}