【赵渝强老师】Kafka生产者的消息发送方式原创

本节课我们来讨论一下卡夫卡生产者的消息发送方式。卡夫卡是一个分布式的消息发布与订阅系统，其动生产者producer负责发送消息，消息可以是支付券，也可以是对象消费者consumer负责消费处理消息。这里重点讨论一下卡夫卡生产者的消息发送方式，它支持三种不同的方式，方式因fire and forget, 该方式把消息发送给卡夫卡的之后，物关行情是否正常到达，即使出现错误，生产者也会自动重事。但这种方式可能造成卡夫卡波克没有接收到生产者消息。因此这种方式适用于允许消息的丢失并对吞吐量要求大的场景。比如用户点击日志上传。方式2，同步发送该方式下，生产者使用剩的方法发送一条消息，该方法会返回一个future对象。调用该对象的get方法可以阻塞当前线程并等待返回。这种方式适用对消息可靠性要求较高的场景，比如支付的场景，在这种场景下要求消息不可丢失，如果丢失了将回滚相关的业务操作方式三异不发送。该方式下生产者使用甚至方法。发送一条消息时需要指定回调函数，该回调函数可以进行错误日志的记录或者重生。这种方式牺牲一部分可靠性，但是吞吐量会比同步发送高很多。这三种方式的区别在于。

对于消息是否正常，道德的处理方式不同，现在你已经知道卡夫卡生产者的消息发送方式了，那你知道卡夫卡生产者消息发送的过程吗？欢迎评论区留言讨论好了，记得点加号关注赵玉强老师。