Scala：如何调用接收Map[TopicPartition,OffsetAndMetadata]的commitSync方法？

嘿，这事儿很简单，我给你拆解成几步来做，一看就懂～

首先，你需要先创建好要提交的分区对象和对应的偏移量元数据对象，接着把它们组装成Scala的Map，最后直接传给commitSync方法就可以了。下面是完整的示例：

1. 实例化必要的对象 #

先创建TopicPartition（指定主题名和分区号）和OffsetAndMetadata（指定要提交的偏移量）的实例：

// 示例：创建两个分区的对象和对应的偏移量
val topicPartition0 = new TopicPartition("your_topic_name", 0)
val offsetMeta0 = new OffsetAndMetadata(12345L) // 这里的12345是你实际要提交的偏移量值

val topicPartition1 = new TopicPartition("your_topic_name", 1)
val offsetMeta1 = new OffsetAndMetadata(67890L)

2. 组装成Scala Map #

因为commitSync方法接受的参数是Map[TopicPartition, OffsetAndMetadata]，所以把上面的对象配对后放进Map里：

val offsetsToCommit = Map(
  topicPartition0 -> offsetMeta0,
  topicPartition1 -> offsetMeta1
)

3. 调用commitSync方法 #

直接把组装好的Map传进去就行——你的方法内部已经帮你做了Scala到Java集合的转换（asJava），不用额外处理：

commitSync(offsetsToCommit)

单个分区的简化写法 #

如果只需要提交单个分区的偏移量，代码可以更简洁：

val singleTp = new TopicPartition("single_topic", 5)
val singleOffset = new OffsetAndMetadata(9876L)
commitSync(Map(singleTp -> singleOffset))

内容的提问来源于stack exchange，提问作者Joe