pub fn kf_encode(&self) -> Vec<CreatableReplicaAssignment> {
            let mut assignments: Vec<CreatableReplicaAssignment> = vec![];
            for partition in &self.partitions {
                assignments.push(CreatableReplicaAssignment {
                    partition_index: partition.id,
                    broker_ids: partition.replicas.clone(),
                })
            }
            assignments
        }
// Encode Replica Assignment map into Kafka Create Replica Assignment
Encode Replica Assignment map into Kafka Create Replica Assignment
Encode Replica Assignment map into Kafka Create Replica Assignment
pub fn kf_encode(&self) -> Vec<CreatableReplicaAssignment> {
            let mut assignments: Vec<CreatableReplicaAssignment> = vec![];
            for partition in &self.partitions {
                assignments.push(CreatableReplicaAssignment {
                    partition_index: partition.id,
                    broker_ids: partition.replicas.clone(),
                })
            }
            assignments
        }
pub fn kf_encode ( & self ) -> Vec < CreatableReplicaAssignment > { let mut assignments : Vec < CreatableReplicaAssignment > = vec ! [ ] ; for partition in & self . partitions { assignments . push ( CreatableReplicaAssignment { partition_index : partition . id , broker_ids : partition . replicas . clone ( ) , } ) } assignments }
Encode Replica Assignment map into Kafka Create Replica Assignment
Encode Replica Assignment map into Kafka Create Replica Assignment
&self
&self