美文网首页
三.kafka0.7 生产者

三.kafka0.7 生产者

作者: symop | 来源:发表于2020-03-21 05:49 被阅读0次

    git地址链接:https://github.com/smipo/mykafka-0.7
    启动类是在test下面的kafka.examples.KafkaProducerDemo无需配置文件
    核心类讲解:
    1.Producer主要是起引导作用
    2.ProducerPool负责管理Producer包括同步和异步的Producer
    3.SyncProducer负责通信
    4.ZKBrokerPartitionInfo负责监听broker的变化
    以上是生产者同步核心类,在0.7版本之后核心主要是异步,以下是异步核心类
    1.AsyncProducer异步生产者的引导
    2.ProducerSendThread异步发送线程

    相关文章

      网友评论

          本文标题:三.kafka0.7 生产者

          本文链接:https://www.haomeiwen.com/subject/ftosyhtx.html