我试图在scala-sbt中运行这个示例kafka生产者代码,但是我总是遇到这个错误。我可以在kafka的0.11.0.0版客户端上看到这个类。
我对sbt和Kafka都是新手,我今天花了一整天的时间来制作一个数据。你能帮忙吗。谢谢
github:www.github.com/axeish/kafkawatcher
我的build.sbt如下:
name := "KafkaWatcher"
version := "1.0"
scalaVersion := "2.12.2"
libraryDependencies += "org.apache.kafka" % "kafka-clients" % "0.11.0.0"
resolvers += Resolver.mavenLocal
我的制作人代码是:
import java.util
import java.util.Properties import org.apache.kafka.clients.producer._
object producer extends App {
val props = new Properties() props.put("bootstrap.server", "localhost:9092"); props.put("acks","1") props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer") props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer")
val producer = new KafkaProducer[String, String](props)
val topic="kafka"
for(i<- 1 to 50) {
val record = new ProducerRecord(topic, "key"+i, "value"+i)
producer.send(record) }
producer.close()
}
我得到了以下错误:
线程“main”java.lang.noclassdeffounderror中出现异常:org/apache/kafka/clients/producer/kafkaproducer位于java.lang.class.getdeclaredmethods0(本机方法)的java.lang.class.privategetdeclaredmethods(类)。java:2701)在java.lang.class.privategetmethodrecursive(class。java:3048)在java.lang.class.getmethod0(class。java:3018)
暂无答案!
目前还没有任何答案,快来回答吧!