Ошибка при создании темы в кафке

Я думаю, что путь, который вы упомянули, неверен. Как говорится в сообщении File Not Found Exception. Ниже приведен пример кода для отправки сообщений в kafka на Java. Предположим, что сервер Kafka работает локально.

`public static void main(String[] args){
    long events = 100000;
    Random rnd  = new Random();

    Properties props = new Properties();
    props.put("metadata.broker.list", "localhost:9092");
    props.put("serializer.class", "kafka.serializer.StringEncoder");
    props.put("partitioner.class", "com.pranjal.kafkatest.SimplePartitioner");
    props.put("request.required.acks", "1");

    ProducerConfig config = new ProducerConfig(props);

    Producer<String, String> producer = new Producer<String, String>(config);

    for(int i=0;i<events;++i){

        long runtime = new Date().getTime();
        String ip    = "192.168.2." + rnd.nextInt(255);

        String msg= "Hello";

        KeyedMessage<String, String> data = new KeyedMessage<String, String>("sentences", ip, msg);
        producer.send(data);
    }
    producer.close();
}`

Вы создаете тему с помощью этой командной строки из документации Kafka?

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

Я столкнулся с той же ошибкой при запуске этого скрипта в Cygwin, и я внес это изменение в bin/kafka-run-class.sh, чтобы решить проблему (аналогично решению пути к классам Cygwin, указанному в шаге 3 первый ответ здесь):

Оригинал:

# Log4j settings if [ -z "$KAFKA_LOG4J_OPTS" ]; then KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:$base_dir/config/tools-log4j.properties" fi

To:

# Log4j settings if [ -z "$KAFKA_LOG4J_OPTS" ]; then KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:$(cygpath -wp $base_dir/config/tools-log4j.properties)" fi

Я запустил сценарий .bat вместо сценария .sh, и это сработало. Мне не пришлось ничего менять.

Первоначально я запускал этот скрипт в git bash;

bin/kafka-console-consumer.sh --boostrap-server localhost:9092 --topic kafkaTopic

и получил следующую ошибку:

$ bin/kafka-console-consumer.sh --boostrap-server localhost:9092 --topic kafkaTopic
log4j:ERROR Could not read configuration file from URL
[file:/c/Users/admin/Documents/kafka/bin/../config/tools-log4j.properties].
java.io.FileNotFoundException: 

\c\Users\admin\Documents\kafka\bin\..\config\tools-log4j.properties
(The system cannot find the path specified)
      at java.io.FileInputStream.open0(Native Method)
      at java.io.FileInputStream.open(FileInputStream.java:195)
      at java.io.FileInputStream.<init>(FileInputStream.java:138)
      at java.io.FileInputStream.<init>(FileInputStream.java:93)
      at sun.net.www.protocol.file.FileURLConnection.connect(FileURLConnection.java:90)
      at sun.net.www.protocol.file.FileURLConnection.getInputStream(FileURLConnection.java:188)
      at org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:557)
      at org.apache.log4j.helpers.OptionConverter.selectAndConfigure(OptionConverter.java:526)
      at org.apache.log4j.LogManager.<clinit>(LogManager.java:127)
      at org.slf4j.impl.Log4jLoggerFactory.<init>(Log4jLoggerFactory.java:66)
      at org.slf4j.impl.StaticLoggerBinder.<init>(StaticLoggerBinder.java:72)
      at org.slf4j.impl.StaticLoggerBinder.<clinit>(StaticLoggerBinder.java:45)
      at org.slf4j.LoggerFactory.bind(LoggerFactory.java:150)
      at org.slf4j.LoggerFactory.performInitialization(LoggerFactory.java:124)
      at org.slf4j.LoggerFactory.getILoggerFactory(LoggerFactory.java:412)
      at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:357)
      at com.typesafe.scalalogging.Logger$.apply(Logger.scala:48)
      at kafka.utils.Log4jControllerRegistration$.<init>(Logging.scala:25)
      at kafka.utils.Log4jControllerRegistration$.<clinit>(Logging.scala)
      at kafka.utils.Logging.$init$(Logging.scala:47)
      at kafka.tools.ConsoleConsumer$.<init>(ConsoleConsumer.scala:45)
      at kafka.tools.ConsoleConsumer$.<clinit>(ConsoleConsumer.scala)
      at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)

Я открыл cmd и выполнил следующую команду:

C:\Users\admin\Documents\kafka\bin\windows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafkaTopic

Выход:

{"message":"Spring Kafka is cool","sender":"Sydney"}

Красиво сработало :)