maven—编译java应用程序以利用kafka

qjp7pelc  于 2021-06-08  发布在  Kafka
关注(0)|答案(3)|浏览(219)

我使用以下方法编写消息生成器:
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

有人知道少了什么吗?
谢谢你的帮助。

h22fl7wq

h22fl7wq1#

我认为正确的进口应该是 org.apache.kafka.clients.producer . 检查 packages 在这里的底部

f1tvaqid

f1tvaqid2#

查看.m2存储库并找到jar(.m2/repository/org/apache/kafka/kafka-clients-0.8.2.0.jar)文件,您将看到导入应该是:
导入org.apache.kafka.clients.producer.producer;

3qpi33ja

3qpi33ja3#

根据我在maven central上的搜索,您定义的依赖项似乎是错误的。

相关问题