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

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

关注编程学问公众号