Kafka producer在设计上要比consumer简单，不涉及复杂的组管理操作，每个producer都是独立进行工作的，与其他producer实例之间没有关联。Producer的主要功能就是向某个topic的某个分区发送消息，所以首先要确认向topic的哪个分区写入消息——即分区器(partitioner)的功能。Kafka producer提供了一个默认的分区器。对于每条待发送的消息而言，如果该消息指定了key，则partitioner会根据key的哈希值来选择目标分区，将具有相同key的所有消息都路由到相同的分区中；若该消息未指定key，则partitioner使用轮询的方式确认目标分区。另外producer的API赋予了用户自行指定目标分区的权力，即用户可以在消息发送时跳过partitioner直接指定到要发送到的分区。Kafka producer在设计上要比consumer简单，不涉及复杂的组管理操作，每个pr
阅读背景：
Kafka生产者producer简要总结
来源：互联网
分享到：
