如何在Scala中公开Kafka的Java方法（带有分区的CommitSync）？

您的Scala代码段看起来正确，这是我填写其余内容的方式：

import org.apache.kafka.clients.consumer.{KafkaConsumer, OffsetAndmetadata}import org.apache.kafka.common.TopicPartitionimport collection.mutable.Mapimport collection.JavaConverters._//initialise your consumer the way you wantval consumer = createKafkaConsumer(config, subscriptions)//you could accept a scala.collection.mutable.Map heredef commitSync(offsets: Map[TopicPartition, OffsetAndmetadata]) = {    //and then convert it to a java.util.Map    consumer.commitSync(offsets.asJava)}