newPartitions.add(part); | clone.add(clonePartitions); | newPartitions.add(part) | newPartitions.add(clonePartitions) | flink | 085d4db849b9c659ba6bb2c7d66a04debeb048c4 | org.apache.flink.streaming.connectors.kafka.KafkaConsumerPartitionAssignmentTest | | | | | | Uses | False |