（一）生產者生成數據的數據，按自定義key做hashcode進行分區
1.Kafka中可以將Topic從物理上劃分成一個或多個分區(Partition)
每個分區在物理上對應一個文件夾，以"topicName_partitionIndex"方式命名
文件夾下存儲這個分區的所有消息(.log)和索引(.index)文件
# 例如Topic:test0320,使用了3個分區,2個副本 186 187 188 ---------- ---------- ---------- test0320-0 test0320-0 test0320-1 test0320-2 test0320-1 test0320-2
2.生產者在生產數據的時候，可以為每條消息自定義Key規則，這樣消息被發送到broker時，會根據分區規則選擇被存儲到哪一個分區中
3.分區規則就是實現了kafka.producer.Partitioner接口的類
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
