kafka随笔

1、kafka producer是线程安全的吗？如何保证的？
2、多个producer并行发送和单个producer发送，哪个吞吐量更大？为什么？
3、kafka的producer客户端的架构是怎样设计的？

4、consumer 心跳过期或者poll时间过久，触发rebalance，谁触发的？谁通知的谁？怎么通知的？
5、consumer客户端的架构是怎样设计的？