blocks|key|70330|text|我在gradle中尝试了以下依赖项。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|70331|compile+group:+'org.apache.kafka',+name:+'kafka-clients',+version:+'2.1.0'|code-block|syntax|javascript|70332|70333|import+java.util.Properties;
import+org.apache.kafka.clients.producer.Callback;
import+org.apache.kafka.clients.producer.KafkaProducer;
import+org.apache.kafka.clients.producer.ProducerConfig;
import+org.apache.kafka.clients.producer.ProducerRecord;
import+org.apache.kafka.clients.producer.RecordMetadata;

public+class+Producer+{

++++public+static+void+main(String[]+args){
++++++++Properties+properties+=+new+Properties();
++++++++properties.put("bootstrap.servers",+"192.168.119.139:9092");
++++++++properties.put("key.serializer",+"org.apache.kafka.common.serialization.StringSerializer");
++++++++properties.put("value.serializer",+"org.apache.kafka.common.serialization.StringSerializer");

++++++++KafkaProducer+kafkaProducer+=+new+KafkaProducer(properties);
++++++++TestCallback+callback+=+new+TestCallback();
++++++++try{
++++++++++++for(int+i+=+0;+i+<+100;+i%2B%2B){
++++++++++++++++System.out.println("----->"%2Bi);
++++++++++++++++kafkaProducer.send(new+ProducerRecord("test",+Integer.toString(i),+"test+message+-+"+%2B+i+));
++++++++++++}
++++++++}catch+(Exception+e){
++++++++++++e.printStackTrace();
++++++++}finally+{
++++++++++++kafkaProducer.close();
++++++++}
++++}


++++private+static+class+TestCallback+implements+Callback+{
++++++++@Override
++++++++public+void+onCompletion(RecordMetadata+recordMetadata,+Exception+e)+{
++++++++++++if+(e+!=+null)+{
++++++++++++++++System.out.println("Error+while+producing+message+to+topic+:"+%2B+recordMetadata);
++++++++++++++++e.printStackTrace();
++++++++++++}+else+{
++++++++++++++++String+message+=+String.format("sent+message+to+topic:%25s+partition:%25s++offset:%25s",+recordMetadata.topic(),+recordMetadata.partition(),+recordMetadata.offset());
++++++++++++++++System.out.println(message);
++++++++++++}
++++++++}
++++}
}|70334|我已经使用Eclipse+IDE测试了这段代码。还要记住，apache+kafka客户端还会下载以下依赖项。|70335|70336|zstd-jni-1.3.5-4.jar|unordered-list-item|70337|lz4-java-1.5.0.jar|70338|snappy-java-1.1.7.2.jar|70339|slf4j-api-1.7.25.jar|70340|70341|如果您希望使用命令运行，则必须使用一组jar文件指定-classpath来运行。下面我提供一个例子。|70342|java.exe+-Dfile.encoding=UTF-8+-classpath+somelocation/a.jar;somelocation/b.jar;somelocation/c.jar|70343|如果它仍然不能解决您的问题，请提供应用程序结构，发布代码详细信息，以便其他人可以帮助您。|70344|entityMap^0|0|0|0|0|0|0|0|0|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|14|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|15|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|16|8|@]|9|@]|A|$]]|$1|H|3|I|5|D|7|17|8|@]|9|@]|A|$E|F]]|$1|J|3|K|5|6|7|18|8|@]|9|@]|A|$]]|$1|L|3|-4|5|6|7|19|8|@]|9|@]|A|$]]|$1|M|3|N|5|O|7|1A|8|@]|9|@]|A|$]]|$1|P|3|Q|5|O|7|1B|8|@]|9|@]|A|$]]|$1|R|3|S|5|O|7|1C|8|@]|9|@]|A|$]]|$1|T|3|U|5|O|7|1D|8|@]|9|@]|A|$]]|$1|V|3|-4|5|6|7|1E|8|@]|9|@]|A|$]]|$1|W|3|X|5|6|7|1F|8|@]|9|@]|A|$]]|$1|Y|3|Z|5|D|7|1G|8|@]|9|@]|A|$E|F]]|$1|10|3|11|5|6|7|1H|8|@]|9|@]|A|$]]|$1|12|3|-4|5|6|7|1I|8|@]|9|@]|A|$]]]|13|$]]

I had tried with the following dependency in gradle.

<pre><code>compile group: 'org.apache.kafka', name: 'kafka-clients', version: '2.1.0'
</code></pre>

Also, I provide below the code snippet for which I tested.

<pre><code>import java.util.Properties;
import org.apache.kafka.clients.producer.Callback;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.RecordMetadata;

public class Producer {

 public static void main(String[] args){
 Properties properties = new Properties();
 properties.put("bootstrap.servers", "192.168.119.139:9092");
 properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
 properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

 KafkaProducer kafkaProducer = new KafkaProducer(properties);
 TestCallback callback = new TestCallback();
 try{
 for(int i = 0; i &lt; 100; i++){
 System.out.println("-----&gt;"+i);
 kafkaProducer.send(new ProducerRecord("test", Integer.toString(i), "test message - " + i ));
 }
 }catch (Exception e){
 e.printStackTrace();
 }finally {
 kafkaProducer.close();
 }
 }


 private static class TestCallback implements Callback {
 @Override
 public void onCompletion(RecordMetadata recordMetadata, Exception e) {
 if (e != null) {
 System.out.println("Error while producing message to topic :" + recordMetadata);
 e.printStackTrace();
 } else {
 String message = String.format("sent message to topic:%s partition:%s offset:%s", recordMetadata.topic(), recordMetadata.partition(), recordMetadata.offset());
 System.out.println(message);
 }
 }
 }
}
</code></pre>

I have tested this code using Eclipse IDE. Also remember, apache kafka client also downloads the following dependencies.

<ul>
<li>zstd-jni-1.3.5-4.jar</li>
<li>lz4-java-1.5.0.jar</li>
<li>snappy-java-1.1.7.2.jar</li>
<li>slf4j-api-1.7.25.jar</li>
</ul>

If you want to run using command you have to run by specifying the -classpath with a set of jar files. I provide an example below.

<pre><code>java.exe -Dfile.encoding=UTF-8 -classpath somelocation/a.jar;somelocation/b.jar;somelocation/c.jar
</code></pre>

If it still does not solve your problem, provide the application structure, post code details so that others can help you.

blocks|key|70886|text|我跑了一下：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|70887|java+-jar+TestProejct-1.0-SNAPSHOT.jar+-cp+"D:\Software\kafka_2.12-2.2.0\libs\kafka-clients-2.2.0.jar"|code-block|syntax|javascript|70888|有几个问题：|70889|70890|java不能同时接受-jar和-cp，所以除了Kafka之外，我还必须在类路径中包含我的jar。|ordered-list-item|70891|我必须指定我想要运行的主类。|70892|有多个jar要从Kafka导入，所以我必须指定*+insead+of+java|70893|70894|这就解决了这个问题：|70895|java+-cp+"D:\Software\kafka_2.12-2.2.0\libs\*;TestProejct-1.0-SNAPSHOT.jar"+SimpleProducer|70896|entityMap^0|0|0|0|0|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|X|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|Y|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|Z|8|@]|9|@]|A|$]]|$1|I|3|-4|5|6|7|10|8|@]|9|@]|A|$]]|$1|J|3|K|5|L|7|11|8|@]|9|@]|A|$]]|$1|M|3|N|5|L|7|12|8|@]|9|@]|A|$]]|$1|O|3|P|5|L|7|13|8|@]|9|@]|A|$]]|$1|Q|3|-4|5|6|7|14|8|@]|9|@]|A|$]]|$1|R|3|S|5|6|7|15|8|@]|9|@]|A|$]]|$1|T|3|U|5|D|7|16|8|@]|9|@]|A|$E|F]]|$1|V|3|-4|5|6|7|17|8|@]|9|@]|A|$]]]|W|$]]

I ran:

<pre><code>java -jar TestProejct-1.0-SNAPSHOT.jar -cp "D:\Software\kafka_2.12-2.2.0\libs\kafka-clients-2.2.0.jar"
</code></pre>

There were several problems:

<ol>
<li>java doesn't aceept both -jar and -cp, so I had to include my jar in the classpath itself in addition to Kafka.</li>
<li>I had to specify the main class I wanted to run.</li>
<li>There was more than one jar to import from Kafka, so I had to specify * insead of kafka-clients-2.2.0.jar.</li>
</ol>

This solved the problem:

<pre><code>java -cp "D:\Software\kafka_2.12-2.2.0\libs\*;TestProejct-1.0-SNAPSHOT.jar" SimpleProducer
</code></pre>

I'm trying to use Kafka:

<pre><code>import java.util.Properties;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;

public class SimpleProducer {
 public static void main(String[] args) {
 Properties props = new Properties();
 Producer&lt;String, String&gt; producer = new KafkaProducer&lt;String, String&gt;(props);
 }
}
</code></pre>

But getting the following error:

<blockquote>
 java.lang.NoClassDefFoundError:
 org/apache/kafka/clients/producer/Producer
</blockquote>

build.gradle:

<pre><code>...

dependencies {
 testCompile group: 'junit', name: 'junit', version: '4.12'
 compile group: 'org.apache.kafka', name: 'kafka-clients', version: '2.2.0'
}

...
</code></pre>

java.lang.NoClassDefFoundError: org/apache/kafka/clients/producer/Producer

Eclipse

Kafka

我正在尝试使用Kafka：import java.util.Properties;import org.apache.kafka.clients.producer.Producer;import org.apache.kafka.clients.producer.KafkaProducer;import org.apa...

问java.lang.NoClassDefFoundError: org/apache/kafka/客户端/生产者/生产者
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问java.lang.NoClassDefFoundError: org/apache/kafka/客户端/生产者/生产者EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问java.lang.NoClassDefFoundError: org/apache/kafka/客户端/生产者/生产者
EN