生产者

producer.send(new ProducerRecord<>("topic", "message"), new Callback() {
    public void onCompletion(RecordMetadata metadata, Exception e) {
        if (e != null) e.printStackTrace();
    }
});