在Scala中处理Java方法'paused()'？ [复制]

Question

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

这是原始的Java方法：

pause(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 pauseMethod (topic_partition) = {
    //and then convert it to a java
    consumer.pause(topic_partition)
}

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

Answer 1

听起来您将paused() 与pause(Collection) 混淆了。 KafkaConsumer 没有paused(Collection) 函数。您不必公开任何内容，因此只需直接调用 pause 函数即可。

使用有限的代码示例，您可以通过以下方式暂停和检索暂停的主题

val consumer = createKafkaConsumer(config, subscription)

consumer.pause(Seq("topic1","topic2").asJava)
println(consumer.paused().asScala)

请注意，Scala 集合使用 asJava 转换为 java，Java 集合使用反函数 asScala 转换为 Scala。

希望这是您所追求的，否则请提供一个功能最少的代码示例以及澄清问题。