(一)生產者生成數據的數據,按自定義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接口的類
網站標題:【kafka】自定義分區規則
文章網址:http://vcdvsql.cn/article16/jhgcdg.html
成都網站建設公司_創新互聯,為您提供電子商務、靜態網站、外貿網站建設、網站導航、關鍵詞優化、服務器托管
聲明:本網站發布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創新互聯