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)