kafka 异常 Exception thrown when sending a message with key='null'

kafka | 2019-09-19 09:11:14

使用java发送kafka消息异常，之前还是正常的，异常信息：

2019-09-19 08:38:27 [ERROR] [kafka-producer-network-thread | producer-1] - Exception thrown when sending a message with key='null' and payload='/tmp/

然后我使用命令行客户端试了一下也出现异常：

/kafka-console-producer.sh --broker-list slave203:6667 --topic designTopic
>s
[2019-09-19 08:56:04,747] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2019-09-19 08:56:04,800] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2019-09-19 08:56:04,953] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2019-09-19 08:56:05,155] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2019-09-19 08:56:05,562] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

之前还是正常的 好吧，这个怎么解决？

登录后即可回复 登录 | 注册
    
  • admin
    admin

    确定IP配置正确，重启kafka和zookeeper就可以了

相关文章
spark异常 could not locate executable null bin winutils.exe in the hadoop binariesdruid数据库连接池异常connection holder is nullkafka发送消息失败error when sending message to topic test1 with key null解决kafka异常error while fetching metadatakafka 异常 exception thrown when sending a message with key= null java jdbc连接phoenix hbase异常clientpath null serverpath null finished falsephp 预定义异常 exceptionphp errorexception 构造一个异常（exception）php exception 异常克隆php exception 异常构造函数php exception 获取异常代码php exception 创建异常时的程序文件名称php exception 获取创建的异常所在文件中的行号php exception 获取字符串类型的异常追踪信息php exception 将异常对象转换为字符串php sybase 函数 sets the handler called when a server message is raisedphp solrserverexception returns internal information where the exception was thrownphp swoole server used in task process for sending result to the worker process when the task is finished.php yar server exception 获取异常的原始类型ImageIO.read()读取图片异常Unsupported Image Type_exception Unsupported Image Type
关注编程学问公众号