Error when sending message to topic test with key: null, value: 2 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)

本文转载自查看原文 2017-12-04 20:17 9874 kafka

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

免责声明！

本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。

猜您在找 springcloud 集成kafka问题记录，发消息报错：ERROR o.s.kafka.support.LoggingProducerListener - Exception thrown when sending a message with key='null' and payload='{-1, spring boot 整合kafka 报错 Exception thrown when sending a message with key='null' and payload=JSON to topic proccess_trading_end: TimeoutException: Failed to update metadata after 60000 ms. Kafka遇到30042ms has passed since batch creation plus linger time at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:94) kafka创建topic报错ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException ERROR:"org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /config/topics/test" when creating or deleting Kafka operations authorized through the Ranger policies kafka删除topic后再创建同名的topic报错（ERROR org.apache.kafka.common.errors.TopicExistsException）启动kafka生产者报错： WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) 【原创】大叔问题定位分享（9）oozie提交spark任务报 java.lang.NoClassDefFoundError: org/apache/kafka/clients/producer/KafkaProducer kafka producer生产数据到kafka异常：Got error produce response with correlation id 16 on topic-partition...Error: NETWORK_EXCEPTION 报错：Bootstrap broker basecoalmine:2181 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)