def METHOD_NAME(
    self,
    entity: PostProcessForwarderType,
    consumer_group: str,
    topic: Optional[str],
    commit_log_topic: str,
    synchronize_commit_group: str,
    concurrency: int,
    initial_offset_reset: Union[Literal["latest"], Literal["earliest"]],
    strict_offset_reset: bool,
) -> None:
    assert not self.requires_post_process_forwarder()
    raise ForwarderNotRequired