def needs_scaling(self, params=None):
        app_config = config.get_config()
        stream_ids = app_config.general.get_autoscaling_kinesis_streams()
        return self.id in stream_ids