def run_command(self):
        """Replication factor command, checks replication factor settings and compare it with
        min.isr in the cluster."""
        topics = get_topic_partition_metadata(self.cluster_config.broker_list)

        topics_with_wrong_rf = _find_topics_with_wrong_rp(
            topics,
            self.zk,
            self.args.default_min_isr,
        )

        errcode = status_code.OK if not topics_with_wrong_rf else status_code.CRITICAL
        out = _prepare_output(topics_with_wrong_rf, self.args.verbose)
        return errcode, out
def run_command ( self ) : topics = get_topic_partition_metadata ( self . cluster_config . broker_list ) topics_with_wrong_rf = _find_topics_with_wrong_rp ( topics , self . zk , self . args . default_min_isr , ) errcode = status_code . OK if not topics_with_wrong_rf else status_code . CRITICAL out = _prepare_output ( topics_with_wrong_rf , self . args . verbose ) return errcode , out
Replication factor command, checks replication factor settings and compare it with
        min.isr in the cluster.