第38课:Kafka源码解读Producer工作机制内幕
1 producer 代码实例
2 producer 源码揭密
kafka 动态元数据刷新,对发送者而言,分布式和单机版没有多大区别,只是吞吐量区别。 几种情况: 分区丢失 leader not available broker挂掉 broker扩容
同步:producer 生产消息以后,立即发送给broker 异步:中间弄一个消息队列,作缓冲;producer 生产消息将消息发给消息队列,然后弄一个线程发送给broker
CallBack都是异步的