先把生产者修改成同步等待,看看报什么错:
producer.send(new ProducerRecord(topic,json.toString())).get()