def _process_metadata_response(topics, zk, default_min_isr):
    """Returns not in sync partitions."""
    not_in_sync_partitions = []
    for topic_name, partitions in topics.items():
        min_isr = get_min_isr(zk, topic_name) or default_min_isr
        if min_isr is None:
            continue
        for metadata in partitions.values():
            cur_isr = len(metadata.isr)
            if cur_isr < min_isr:
                not_in_sync_partitions.append({
                    'isr': cur_isr,
                    'min_isr': min_isr,
                    'topic': metadata.topic,
                    'partition': metadata.partition,
                })

    return not_in_sync_partitions
def _process_metadata_response ( topics , zk , default_min_isr ) : not_in_sync_partitions = [ ] for topic_name , partitions in topics . items ( ) : min_isr = get_min_isr ( zk , topic_name ) or default_min_isr if min_isr is None : continue for metadata in partitions . values ( ) : cur_isr = len ( metadata . isr ) if cur_isr < min_isr : not_in_sync_partitions . append ( { 'isr' : cur_isr , 'min_isr' : min_isr , 'topic' : metadata . topic , 'partition' : metadata . partition , } ) return not_in_sync_partitions
Returns not in sync partitions.