首页 笔记 图片 查字 
所属分类:Kafka
浏览:42
内容:

异步发送:
Main线程不断的向RecordAccumlator消息累加器添加数据,不需要等到sender线程将其之前的数据发送完成。
同步发送:
Main线程向RecordAccumlator消息累加器添加数据,需要等到sender线程将其之前的数据发送完成。

1、异步发送:
默认的发送方式,KafkaProducer类send()方法就是异步发送。

2、异步回调发送:
send()方法中添加回调函数Callback()实现。

3、同步发送:
在异步send()方法的后面调用get()方法即可。