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

相关文章
spring kafkatemplate 实现 kafka 发送 接受 消息 案例代码kafka 控制台生产发送消息测试命令kafka发送消息失败error when sending message to topic test1 with key nullkafka 异常 exception thrown when sending a message with key= null jquery.error message jqueryjquery $.error message php cubrid 函数 get last error message for the most recent function callphp cubrid mysql 兼容性函数 get the error messagephp ibm db2 函数 returns the last connection error message and sqlcode valuephp ibm db2 函数 returns a string containing the last sql statement error messagephp informix 函数 returns error message of last informix callphp ldap 函数 return the ldap error message of the last ldap commandphp newt 函数 set a callback function which gets invoked when user presses the suspend keyphp odbc 函数 get the last error messagephp sybase 函数 sets the handler called when a server message is raisedphp mnogosearch 函数 get mnogosearch error messagephp vpopmail 函数 get text message for last vpopmail errorphp intlbreakiterator get last error message on the objectphp intlcalendar get last error message on the objectphp numberformatter get formatter s last error message
关注编程学问公众号