kafka 同步发送消息

同步发送的意思就是，一条消息发送之后，会阻塞当前线程， 直至返回 ack。由于send方法返回的是一个 Future对象，根据 Futrue对象 的特点，我们也可以实现 同步发送的效果 ，只需在调用 Future对象的 get方法即可。

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