def METHOD_NAME(self) -> None:
    """
    Start the process for receiving events.
    """
    self.consumer.receive(
        on_event=self.process_event_sync,
        on_error=self.process_error_sync,
        max_wait_time=self.args.max_wait_time,
        prefetch=self.args.prefetch_count,
        starting_position="-1",  # "-1" is from the beginning of the partition.
    )