KafkaProducer #send() 方法将消息发送至Broker集群。
阅读全文
kafka
kafka
kafka
【源码篇】KafkaProducer初始化源码流程
Kafka版本3.0，从源码层面对KafkaProducer初始化流程进行分析。
阅读全文
kafka
【源码篇】Kafka内存管理BufferPool
为了实现内存的高效利用，基本上每个成熟的框架或者工具都有一套内存管理机制，kafka的生产者使用BufferPool来实现内存(ByteBuffer)的复用。
阅读全文
关于我
数据工匠记
你现在的焦虑和努力里，藏着你十年后的样子。 公众号 【数据工匠记】，专注于大数据领域离线、实时技术干货定期分享！
