迭代地图以创建另一个地图

Question

我正在尝试获取最新提交的偏移量。为此，我需要创建一个（分区 -> 偏移量）的映射示例：{"0"->200,"1"->100} from Consumer.Committed(set [分区]) consumer.committed 在 util.map[TopicPartition,OffsetandMetaData] 中给出输出

在从 util.map[TopicPartition,OffsetandMetaData] 创建地图时需要帮助

  var map = Map[String, Long]() //Empty Map to populate

    val last=consumer.committed(partitions.toSet)


    last.foreach(x=>
      (map += (x._1 -> x._2.offset()))
      //println(x._1 +"->" +x._2.offset())
    )

Answer 1

您可以在Map 上使用map 来生成新的Map：

val map = last.map { case (t, o) => t -> o.offset }