时间戳

首页 > 解决方案 > value create 不是对象 org.apache.kafka.clients.admin.KafkaAdminClient 的成员

scala - value create 不是对象 org.apache.kafka.clients.admin.KafkaAdminClient 的成员

问题描述

我正在尝试KafkaAdminClient.create在 Scala 中使用如下：

import java.util.Properties

import org.apache.kafka.clients.admin.KafkaAdminClient


final class DetectorActor extends TemplateActor {

  val props = new Properties
  props.put("bootstrap.servers", "localhost:9092")
  props.put("connections.max.idle.ms", "10000")
  props.put("request.timeout.ms", "5000")

  val adminClient = {
    val client = KafkaAdminClient.create(props)

  }

  override def receive: Receive = ???
}

它不起作用，因为Scala编译器找不到KafkaAdminClient.create(props)工厂方法。

value create is not a member of object org.apache.kafka.clients.admin.KafkaAdminClient
[error]     val client = KafkaAdminClient.create(props)

我究竟做错了什么？

标签： scala

解决方案

org.apache.kafka.clients.admin.KafkaAdminClient延伸org.apache.kafka.clients.admin.AdminClient。

后者有静态方法create(props: Properties): AdminClient

val client = AdminClient.create(props)

ScaladocKafkaAdminClient说

/**
 * The default implementation of {@link AdminClient}. 
 * An instance of this class is created by invoking one of the
 * {@code create()} methods in {@code AdminClient}. 
 * Users should not refer to this class directly.

https://www.programcreek.com/java-api-examples/index.php?api=org.apache.kafka.clients.admin.AdminClient

推荐阅读