kafka 生产者

kafka 生产者 创建一个包含目标主题和内容的 ProducerRecord 对象,可指定键或分区,发送前要把对象序列化成字符数组。 数据被传给分区器,如果指定了分区就直接把指定的分区返回。如果没有指定分区,分区器就根据 ProducerRecord 对象的键选择一个分区。紧接着这条记录就被添加到一个记录批次里,这个批次里所有的消息会被发送到相同的主题和分区上。 如果消息成功写入 kafka,就返回一个 PrcordMetaData 对象,包含了主题和分区信息,以及记录在分区的偏移量。如果写入失败,则会返回一个错误。生产者在收到错误之后会尝试重新发送消息,几次之后还是失败就会返回错误信息。