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,不然日志会和别的程序的日志混杂在一块,很乱...