spring kafka源码解读

 2019-11-23 11:10  阅读(1541)
文章分类: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) {

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

点赞(0)
版权归原创作者所有,任何形式转载请联系作者; Java 技术驿站 >> spring kafka源码解读

相关推荐