kafka发送消息失败Error when sending message to topic test1 with key: null

kafka | 2019-09-18 12:17:42

升级了一下kafka,因为新kafka可以配置bootstrap.servers，旧版只能配置zookeeper来创建消费者。zookeeper没有动还是原来的，所以topic数据依然在，然后我测试发送消息，出现异常：

#./kafka-console-producer.sh --broker-list slave203:9092 --topic test1
>s
>[2019-09-18 10:41:55,916] ERROR Error when sending message to topic test1 with key: null, value: 1 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for test1-0: 1549 ms has passed since batch creation plus linger time

这是为啥，新的kafka和之前的zookeeper不匹配？还是其他问题？老的数据冲突？

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

    终于找到问题，因为这个topic是之前创建的，我从新创建一个就可以了，或者删除了重新创建，删除topic参考：

    kafka如何删除topic

相关文章
消息中间件rocketmq kafka activemq rabbitmq zeromq对比选型spring kafkatemplate 实现 kafka 发送 接受 消息 案例代码kafka 控制台生产发送消息测试命令kafka发送消息失败error when sending message to topic test1 with key null解决kafka异常error while fetching metadatakafka 异常 exception thrown when sending a message with key= null php cubrid mysql 兼容性函数 return the numerical value of the error message from previous cubrid operationphp frontbase 函数 returns the error message from previous operationphp ldap 函数 convert ldap error number into string error messagephp mqseries 函数 returns the error message corresponding to a result code mqrc php msql 函数 returns error message of last msql callphp postgresql 函数 向 postgresql 后端发送以 null 结尾的字符串php posix 函数 retrieve the system error message associated with the given errnophp radius 函数 returns an error messagephp rrd 函数 gets latest error messagephp mongodb driver writeconcernerror returns the writeconcernerror s error messagephp sam 函数 send a message to a queue or publish an item to a topicphp snmp get last error message解决 php 腾讯企业 发送 邮件异常SMTP Error: Could not authenticatekafka彻底删除topic
关注编程学问公众号