spring kafka源码解读

扫码关注公众号:Java 技术驿站

发送:vip
将链接复制到本浏览器,永久解锁本站全部文章

【公众号:Java 技术驿站】 【加作者微信交流技术,拉技术群】
免费领取10G资料包与项目实战视频资料

spring kafka源码解读

记录下源码的一些东西

  • ProducerFactory
    producerFactory用于创建一个kafka-producer, 默认实现是DefaultKafkaProducerFactory, 会根据原生的new Producer方式生成一个全局变量producer(CloseSafeProducer),KakfaProducer是线程安全的,所以一个应用中只需要一个KakfaProducer就可以了。 CloseSafeProducer是kafka-producer的代理类,以便在Lifecycle, DisposableBean关闭时关闭KakfaProducer。
  • KafkaProducer
    kafka客户端源码,用于发送消息。具体构造过程
    private KafkaProducer(ProducerConfig config, Serializer keySerializer, Serializer valueSerializer) {

来源:http://ddrv.cn/a/88268

赞(0) 打赏
版权归原创作者所有,任何形式的转载请联系博主:daming_90:Java 技术驿站 » spring kafka源码解读

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏