发了10000个数据

结果
callback total time :167
async total time :487

    void asyncSend() throws ExecutionException, InterruptedException {
        Producer<String, String> producer = initProducer();

        //producer record
        long in = System.currentTimeMillis();
        for(int i = 0 ;  i< 10000; i++) {
            ProducerRecord<String, String> record =
                    new ProducerRecord<String, String>(TOPIC_NAME,"key-"+i, "sync "+System.currentTimeMillis());

            Future<RecordMetadata> send = producer.send(record);
//            System.out.println(send.get().toString());
        }
        long out = System.currentTimeMillis();
        System.out.println("async total time :" + (out - in));
    }

    void callBackSend() throws ExecutionException, InterruptedException {
        Producer<String, String> producer = initProducer();
        //producer record

        long in = System.currentTimeMillis();
        for(int i = 0 ;  i< 10000; i++) {
            ProducerRecord<String, String> record =
                    new ProducerRecord<String, String>(TOPIC_NAME,"key-"+i, "async "+System.currentTimeMillis());

            Future<RecordMetadata> send = producer.send(record, new Callback() {
                @Override
                public void onCompletion(RecordMetadata recordMetadata, Exception e) {
//                    System.out.println("partition: " + recordMetadata.partition());
                }
            });
        }

        long out = System.currentTimeMillis();
        System.out.println("callback total time :" + (out - in));
    }

我本来预计两个应该差不多的