我是java新手,必须执行与kafka相关的代码片段,如下所示:
import java.util.*;
import org.apache.kafka.clients.producer.*;
public class Producer {
public static void main(String[] args) throws Exception
{
String topicName = "SimpleProducerTopic";
String key = "Key1";
String value = "Value-1";
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092,localhost:9093");
props.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
Producer<String, String> producer = new KafkaProducer <>(props);
ProducerRecord<String, String> record = new ProducerRecord<>(topicName,key,value);
producer.send(record);
producer.close();
System.out.println("SimpleProducer Completed.");
}
}
我已经下载了intellijidea编辑器并在那里运行了上面的脚本,但是它给了我一个错误
错误:(2,1)java:package org.apache.kafka.clients.producer不存在
我知道apachekafka不见了,所以我下载了apache的jar文件并将其添加到模块中,但错误仍然存在。我该怎么办?如何安装 Package ?
3条答案
按热度按时间x9ybnkn61#
简单地将jar添加到相应的模块并不能让您访问它。你试过右击jar的addas库吗。。。选择?
编辑:您也许可以探索外部库使用的其他选项,如maven或gradle。
smtd7mpg2#
安装包的一种方法是使用maven。如果您想配置maven和intellij,请看一下本教程。最后,完成后,应该将其添加到自动生成的
pom.xml
文件:您可以在
<dependencies></dependencies>
标签。网上有很多关于如何使用maven处理依赖关系的教程。zbdgwd5y3#
作为java新手,您需要了解什么是类路径。
将jar直接放入ide并不能改变这一点
即使在命令行中,也需要显式指定
-cp kafka-clients.jar
在intellij中修改模块类路径有多种方法,但是应该避免手动下载jar,这个问题可以通过maven或gradle(或sbt)等依赖管理工具来解决您的概要文件提到了其他语言,所以请考虑nuget、npm、pip等。将这些知识应用到java中