在Scala中处理Java方法'paused()‘吗？
在Scala中处理Java方法'paused()‘吗？
提问于 2018-04-27 20:21:46
我正在尝试通过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中调用(和传递参数)此方法？谢谢。
回答 1
Stack Overflow用户
发布于 2018-04-27 20:50:49
听起来你好像把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的。
希望这就是你想要的，否则请提供一个功能最少的代码样本以及澄清的问题。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/50069777
复制
![[golang]在Go中处理时区](https://ask.qcloudimg.com/http-save/yehe-2150866/9fvdgusn1y.png)
相似问题
Mockito可以处理在Scala中返回泛型的方法吗？
Scala:处理Java库异常的最佳方法？
scala - Java互操作-可以从Scala中“选择”被调用的java方法吗？
在Scala中调用私有Java方法
在Scala中实现Java接口方法
添加站长 进交流群
领取专属 10元无门槛券
AI混元助手 在线答疑
关注 腾讯云开发者公众号
洞察 腾讯核心技术
剖析业界实践案例
腾讯云开发者
