Я новичок в 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.");
}
}
Я скачал редактор IntelliJ Idea и запустил там вышеуказанный скрипт, но он дает мнеошибка
Ошибка: (2, 1) java: пакет org.apache.kafka.clients.producer не существует
Я знаю, что я apache kafka отсутствуетпоэтому я скачал jar-файл apache и добавил его в модули, но ошибка все еще сохраняется.Что я должен делать?Как установить пакет?