【赵渝强老师】Kafka生产者的执行过程原创

本节课我们来讨论一下卡夫卡生产者的执行过程。卡发卡是一个分布式的消息发布与订阅系统，其中的生产者producer负责发送消息，消息可以是支付串，也可以是对象消费者consumer负责消费处理消息。这里重点讨论一下卡夫卡生产者producer的执行过程。生产者Producer有两个线程协调运行，他们分别是主线程和生ER线程。在主线程中，卡夫卡R会创建一个producer record对象，该对象代表了生产者发送到卡夫卡服务器端的一条消息。Producer recorder创建成功后，需要经过拦截性分区器、序列化器，最终被转换为字节数组，这样他们才能够在网络上传输卡夫卡丢失的创建消息，最终会缓存到生产者的消息雷达器中。并由发送线程负责将其发送到卡布卡集群的博客中。如果消息写入成功，卡夫卡博客会返回一个record的迈特data对象，它包含了主题分区和时间错信息，以及消息在分区的偏移量。如果消息发送失败，卡夫卡博克会返回一个错误。生产者在收到错之后会尝试重新发送消息，如果几次尝试之后还是失败的话，生产者就会返回错误。现在你已经知道卡夫卡生产者的执行过程了，那你知道卡夫卡生产者的消息发送方式有几种吗？欢迎评论区里面讨论，好了，记得点加号关注赵玉强老师。