def METHOD_NAME(self, timeout: Optional[float] = None) -> None:
    if self.__batch:
        last = self.__batch.messages[-1]
        logger.debug(
            f"Abandoning batch of {len(self.__batch)} messages...latest offset: {last.committable}"
        )
    self.__next_step.close()
    self.__next_step.METHOD_NAME(timeout)