成功案例
您当前的位置:主页 > 成功案例 >

kafkaproducer实例及原理分析

更新时间:2021-01-10

  上面的0分区的日记讯息显示,tlbb的5条数据都被蓄积了2遍,而且能够涌现正在分区内,都是有序的。

  咱们能够供应Partitioner,如此能够使得数据依照咱们的计谋来存储正在brokers中。

  须要小心的是,POJO对象须要序列化转化成KAFKA识其它音信存储方式--byte[]

  假设,公司有一款逛戏,须要做行动统计说明,数据的源流来自日记,因为用户行动分外众,导致日记量分外大。将日记数据插入数据库然后再举办说明,仍然满意不了。

  b.小心producer实例化时的泛型。value是音信对象,即POJO,key是这个pojo的标示,这个是要用来举办分区的。

  可睹,broker(id=0),broker(id=1)他们的分区数据一律相似,这也便是为什么kafka的高可用性,某些broker挂了,其他的broker还能够接续供应效劳和数据。

  因为咱们只修筑了2种appkey的数据,遵循分区函数,只会返回2个partition number,因而导致有一个分区没稀有据。

  上述进程,正在我的博客【搭修kafka运转处境】内里都有仔细记载,众人能够参考。

400-123-4567
地图
地址:广东省广州市天河区88号
电话:400-123-4567
传真:+86-123-4567
邮箱:admin@jshtss.com
网站地图
地址:广东省广州市天河区88号    电话:400-123-4567    传真:+86-123-4567
Copyright © 2019 人人彩票天然有机料有限公司 版权所有