在测试kafka写入数据的时候一直在报错:
...
[org.apache.kafka.clients.NetworkClient:600] - Error while fetching metadata with correlation id 589 : {TEST_RECEIVE_TOPIC=UNKNOWN_TOPIC_OR_PARTITION}
[org.apache.kafka.clients.NetworkClient:600] - Error while fetching metadata with correlation id 590 : {TEST_RECEIVE_TOPIC=UNKNOWN_TOPIC_OR_PARTITION}
[org.apache.kafka.clients.NetworkClient:600] - Error while fetching metadata with correlation id 591 : {TEST_RECEIVE_TOPIC=UNKNOWN_TOPIC_OR_PARTITION}
...
原因是没有创建kafka的topic,先用命令行执行topic创建命令。后可以正常写入。