0
respostas

Comandos não encontram o file \config\tools-log4j.properties e não está consumindo mensagens

$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic banana_teste_v01 --from-beginning
log4j:ERROR Could not read configuration file from URL [file:/c/Users/lixo/kafka_2.13-2.6.0/bin/../config/tools-log4j.properties].
java.io.FileNotFoundException: \c\Users\lixo\kafka_2.13-2.6.0\bin\..\config\tools-log4j.properties (O sistema n▒o pode encontrar o caminho especificado)
        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:1                                                                          88)
        at org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:557)
        at org.apache.log4j.helpers.OptionConverter.selectAndConfigure(OptionConverter.java:52                                                                          6)
        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:417)
        at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:362)
        at com.typesafe.scalalogging.Logger$.apply(Logger.scala:48)
        at kafka.utils.Log4jControllerRegistration$.<clinit>(Logging.scala:25)
        at kafka.tools.ConsoleConsumer$.<clinit>(ConsoleConsumer.scala:46)
        at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
log4j:ERROR Ignoring configuration file [file:/c/Users/lixo/kafka_2.13-2.6.0/bin/../config/tools-log4j.properties].
log4j:WARN No appenders could be found for logger (kafka.utils.Log4jControllerRegistration$).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.

obs: Eu produzi as mensagens abaixo mas o comando acima não consumiu:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic banana_teste_v01
..
log4j:WARN No appenders could be found for logger (kafka.utils.Log4jControllerRegistration$).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
>teste1,b1,1234567890123456,333333333333,123.00
>teste2,b2,1111111111111111,636381628191,231.20
>teste3,b3,22222222222222222,92340348302,9172.00