kafka 同步發送消息

同步發送的意思就是，一條消息發送之后，會阻塞當前線程， 直至返回 ack。由於send方法返回的是一個 Future對象，根據 Futrue對象 的特點，我們也可以實現 同步發送的效果 ，只需在調用 Future對象的 get方法即可。

    //發送數據
    for(int i = 11 ;i <= 20;i++) { producer.send(new ProducerRecord<String, String>("two","kpwong--"+i)).get(); }