软件研发
Kafka生产者 标签描述

生产者创建消息。在其他基于发布与订阅的消息系统中,生产者可能被称为发布者或写入者。 一般情况下,一个消息会被发布到一个特定的主题上。生产者在默认情况下把消息均衡地分布到主题的所有分区上,而并不关心特定消息会被写到哪个分区。不过,在某些情况下,生产者会把消息直接写到指定的分区。这通常是通过消息键和分区器来实现的,分区器为键生成一个散列值,并将其映射到指定的分区上。这样可以保证包含同一个键的消息会被写到同一个分区上。生产者也可以使用自定义的分区器,根据不同的业务规则将消息映射到分区。 生产者发送消息的方式 生产者发送消息主要有2种方式:同步发送消息、异步发送消息 同步发送消息 同步发送消息:我们调...