【发布时间】:2020-11-07 18:04:00
【问题描述】:
我是 Java 新手,我必须执行与 Kafka 相关的代码 sn-p,如下所示:
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.");
}
}
我已经下载了 IntelliJ Idea 编辑器并在那里运行上面的脚本,但它给了我一个错误
Error:(2, 1) java: package org.apache.kafka.clients.producer 没有 存在
我知道我缺少 apache kafka,所以我下载了 apache 的 jar 文件并将其添加到模块中,但错误仍然存在。我应该怎么办?如何安装包?
【问题讨论】:
-
尝试使用maven进行依赖管理...
标签: java intellij-idea apache-kafka