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