馬老師分布式定時(shí)任務(wù)調(diào)度解析
2023-04-02 14:15 作者:三國(guó)盡歸許佳琪 | 我要投稿
int partitionNum = Integer.parseInt((String) key);**
** return Math.abs(Integer.parseInt((String) key) % numPartitions);**
** }catch(Exception e) {**
** return Math.abs(key.hashCode() % numPartitions);**
** }**
** }**
}
** 如果將上例中的class作為partition.class，并通過(guò)如下代碼發(fā)送20條消息（key分別為0，1，2，3）至topic2（包含4個(gè)partition）。**
public void sendMessage()throws InterruptedException{
標(biāo)簽：
