在Scala中公开Java方法（带参数）？ [复制]

Question

我正在尝试通过 Scala 公开 Java 方法（有关原始 Java 方法的更多详细信息 - 它来自 Kafka）

这是原始的Java方法：

public void resume(Collection<TopicPartition> partitions)

如何向 Scala 中的方法公开和传递参数，以及在这种情况下使用哪个 Scala 集合？
我有类似的东西：

import org.apache.kafka.clients.consumer.{KafkaConsumer, OffsetAndMetadata}
import org.apache.kafka.common.TopicPartition

import collection.mutable.Map
import collection.JavaConverters._

//initialise consumer:
var consumer = createKafkaConsumer(config, subscriptions)

//accept a scala.collection.mutable.Map here
def commitSync(offsets: scala.collection.mutable.ArrayBuffer) = {
    //and then convert it to a java
    consumer.resume(offsets.asJava)
}

另外，如何在 Scala 中调用（并传递参数）这个方法？
谢谢。

Answer 1

更新

啊，对。试试这个：

import org.apache.kafka.clients.consumer.KafkaConsumer
import org.apache.kafka.common.TopicPartition

import collection.mutable.ArrayBuffer
import collection.JavaConverters._

//initialise consumer:
val consumer = createKafkaConsumer(config, subscriptions) // Make this a val!

//accept a scala.collection.mutable.ArrayBuffer here
def commitSync(offsets: ArrayBuffer[TopicPartition]) = {
  //and then convert it to a java
  consumer.resume(offsets.asJava)
}

看起来 ArrayBuffer 需要包含TopicPartition 实例，以便将其转换为TopicPartition 的Java 集合，以便resume 调用起作用。

在 Scala 中，您总是需要输入集合的类型参数。

我假设您知道 TopicPartition 实例的外观，因为它是 Kafka 的一部分。 （阅读API Docs if you're unsure。）

为了调用commitSync 函数，您需要ArrayBuffer 的TopicPartition 实例。例如：

val topics: ArrayBuffer[TopicPartition] = ArrayBuffer(
  new TopicPartition("sometopicname", somePartitionNum),
  new TopicPartition("someothertopic", someOtherPartitionNum),
  // etc.
)
commitSync(topics)