为什么kafka producer抛出java.lang.noclassdeffounderror:kafka producer

uqxowvwt  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(392)

我试图在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)

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题