95-40-014-生产者-KafkaProducer

Posted 2021-09-01 九师兄

文章目录

• 1.视界
• 1. 生产者案例
• 2. KafkaProducer整体流程
• 3. blocking vs non-blocking
• • • partition
    • RecordAccumulator

1.视界

1. 生产者案例

生产者线程:异步发送消息,提供一个Callback;同步发送消息,则调用Future.get()会Block住直到结果返回.

public class Producer