kafka(三): 数据生产流程,数据复制与Replica Failover

【这是一篇7月份躺在草稿箱的文章,今天翻出来整理一下。】 数据生产流程 1.发送到kafka的数据会封装为ProducerRecord对象,包含topic、partition、key、value信息; 2.调用send()方法后,将数据序列化为字节数组,如果没有指定分区 ,那么分区器会根据ProducerRecord 对象的键来计算一个分区; 3.当消息达到一个批次设定的量(消息放在缓冲区中),通
相关文章
相关标签/搜索