zoukankan      html  css  js  c++  java
  • kafka数据分区的四种策略

    kafka的数据的分区

    探究的是kafka的数据生产出来之后究竟落到了哪一个分区里面去了
    第一种分区策略:给定了分区号,直接将数据发送到指定的分区里面去
    第二种分区策略:没有给定分区号,给定数据的key值,通过key取上hashCode进行分区
    第三种分区策略:既没有给定分区号,也没有给定key值,直接轮循进行分区
    第四种分区策略:自定义分区

    /// /    producer.send(new ProducerRecord<String, String>("test", Integer.toString(i), Integer.toString(i)));
    //kafka的第一种分区方式,如果给定了分区号,那么就直接将数据发送到指定的分区号里面去
    //producer.send(new ProducerRecord<String, String>("test",2,"helloworld",i+""));
    //kafka的第二种分区策略,没有给定分区号,给定了数据的key,那么就通过key取hashcode,将数据均匀的发送到三台机器里面去
    //注意如果实际工作当中,要通过key取上hashcode来进行分区,那么就一定要 保证key的变化,否则,数据就会全部去往一个分区里面
    

    /// producer.send(new ProducerRecord<String, String>("test",i+"",i+""));
    //kafka的第三种分区策略,既没有给定分区号,也没有给定数据的key值,那么就会按照轮循的方式进行数的发送
    producer.send(new ProducerRecord<String, String>("test",i+""));
    //kafka的第四种分区策略,自定义分区类,实现我们数据的分区

  • 相关阅读:
    Oracle 常用的十大 DDL 对象
    Oracle DML
    Oracle 的常用概念
    Spring 4 : 整合 SSH
    Spring3 (事务管理)
    Spring2
    Spring 学习笔记一
    Xpath helper下载
    爬取链家北京市二手房的单个房源页信息
    爬取链家北京市二手房的链家编号
  • 原文地址:https://www.cnblogs.com/alexzhang92/p/11098719.html
Copyright © 2011-2022 走看看