def METHOD_NAME(self, message: Message[KafkaPayload]) -> None:
    assert not self.__closed
    payload = self._get_payload(message)
    self._produce_billing_outcomes(payload)
    self.__commit(message.committable)