windows下使用kafka遇到這個問題: Error when sending message to topic test with key: null, value: 2 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
百度了下,沒找到答案,還是自己看輸出台日志...其實你只要看下輸出台的內容總能找到答案的..
我是看kafka-server-start這個cmd窗口,就是你啟動kafka服務的那個窗口..
從圖中的信息可以看出,創建日志失敗,而且路徑跟我預期的不一樣,一看就知道又是windows和linux文件路徑不同的問題:
#windows下應該改成下邊這樣:
log.dirs=F:/LocalData/kafka_log
或者: log.dirs=F:\\LocalData\\kafka_log
重新啟動即可...
當然每個人遇到這個問題的原因可能不一樣,有的是因為端口號,但總能在日志中找到錯誤信息的...
還有個問題就是log4j.properties這個文件最好修改下,修改如下:
log4j.appender.controllerAppender.File=${kafka.logs.dir}/kafka/controller.log
所有的這種輸出日志的路徑,加上kafka,不然日志會和別的程序的日志混雜在一塊,很亂...