我使用以下方法编写消息生成器:
Maven
java 1.8版
乌班图
我的pom.xml文件包含来自http://kafka.apache.org/documentation.html#theproducer
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.8.2.0</version>
</dependency>
我在这里发布的是我的helloworld.java应用程序的样子:
import kafka.javaapi.producer.Producer;
public class HelloWorld
{
public static void main(String args[])
{
int x = 4;
System.out.println("hello world");
}
}
然后我使用maven编译。
mvn compile
但我得到以下错误。
[ERROR] /home/azureuser/test-application/src/main/java/HelloWorld.java:
[6,30] package kafka.javaapi.producer does not exist
有人知道少了什么吗?
谢谢你的帮助。
3条答案
按热度按时间h22fl7wq1#
我认为正确的进口应该是
org.apache.kafka.clients.producer
. 检查packages
在这里的底部f1tvaqid2#
查看.m2存储库并找到jar(.m2/repository/org/apache/kafka/kafka-clients-0.8.2.0.jar)文件,您将看到导入应该是:
导入org.apache.kafka.clients.producer.producer;
3qpi33ja3#
根据我在maven central上的搜索,您定义的依赖项似乎是错误的。