Currently, the logic in lastCheckpointInternalToStatsSchema in stats_utils.cpp parses on the field name "startingPoint" or "partitions" to differentiate between a change stream source and a kafka source. Change this to parse based on Operator name