def set_consistent(self, consistent_config):
<EOL>self.topology._add_job_control_plane()<EOL>self.oport.operator.consistent(consistent_config)<EOL>return self._make_placeable()<EOL>
Indicates that the stream is the start of a consistent region.

        Args:
            consistent_config(consistent.ConsistentRegionConfig): the configuration of the consistent region.

        Returns:
            Stream: Returns this stream.

        .. versionadded:: 1.11