1. client会把消息封装成ProducerRecord 成员变量是 private final String topic; private final Integer partition; private final Headers headers; private final K key; private final V value; private final Long timestamp;

发送的核心类是KafkaProducer, 核心方法是 doSend,