spring kafka源码解读

2019年3月19日 340次阅读 来源: Spring Cloud

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) {

    原文作者：Spring Cloud
    原文地址: https://blog.csdn.net/luenglau/article/details/78770184
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞