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

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

druid数据库连接池异常connection holder is null 如何解决kafka 异常 no resolvable bootstrap urls given in bootstrap.servers kafka发送消息失败error when sending message to topic test1 with key null 解决kafka异常error while fetching metadata kafka 异常 exception thrown when sending a message with key= null java jdbc连接phoenix hbase异常clientpath null serverpath null finished false php 预定义异常 exception php errorexception 构造一个异常（exception）php exception 异常克隆 php exception 异常构造函数 php exception 获取异常代码 php exception 创建异常时的程序文件名称 php exception 获取创建的异常所在文件中的行号 php exception 获取异常消息内容 php sybase 函数 sets the handler called when a server message is raised php solrclientexception returns internal information where the exception was thrown php solrexception returns internal information where the exception was thrown php 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

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

admin