Remove, setting _stop_requested as this is now in the parent class

morpheus/stages/input/control_message_kafka_source_stage.py

@@ -110,9 +110,6 @@ def __init__(self,
         self._async_commits = async_commits
         self._client = None
 
-        # Flag to indicate whether we should stop
-        self._stop_requested = False
-
         self._poll_interval = pd.Timedelta(poll_interval).total_seconds()
         self._started = False