【kafka】自定義分區規則
（一）生產者生成數據的數據，按自定義key作hashcode進行分區bash
1.Kafka中能夠將Topic從物理上劃分紅一個或多個分區(Partition)ide
每一個分區在物理上對應一個文件夾，以"topicName_partitionIndex"方式命名spa
文件夾下存儲這個分區的全部消息(.log)和索引(.index)文件code
# 例如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接口的類接口
相關文章
- 1. 【kafka】自定義分區規則
- 2. [Kafka基礎]--自定義Kafka分區器
- 3. sonar自定義規則
- 4. Yii2 rules 自定義規則
- 5. sharding-proxy自定義規則
- 6. 自定義規則總結
- 7. adblock自定義規則
- 8. jquery validate 自定義規則
- 9. ThinkPHP Validate自定義規則
- 10. 自定義StyleCop規則
- 更多相關文章...
- • 自定義TypeHandler - MyBatis教程
- • RDF 規則 - RDF 教程
- • RxJava操作符（十）自定義操作符
- • Git五分鐘教程
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. eclipse設置粘貼字符串自動轉義
- 2. android客戶端學習-啓動模擬器異常Emulator: failed to initialize HAX: Invalid argument
- 3. android.view.InflateException: class com.jpardogo.listbuddies.lib.views.ListBuddiesLayout問題
- 4. MYSQL8.0數據庫恢復 MYSQL8.0ibd數據恢復 MYSQL8.0恢復數據庫
- 5. 你本是一個肉體，是什麼驅使你前行【1】
- 6. 2018.04.30
- 7. 2018.04.30
- 8. 你本是一個肉體，是什麼驅使你前行【3】
- 9. 你本是一個肉體，是什麼驅使你前行【2】
- 10. 【資訊】LocalBitcoins達到每週交易比特幣的7年低點
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. 【kafka】自定義分區規則
- 2. [Kafka基礎]--自定義Kafka分區器
- 3. sonar自定義規則
- 4. Yii2 rules 自定義規則
- 5. sharding-proxy自定義規則
- 6. 自定義規則總結
- 7. adblock自定義規則
- 8. jquery validate 自定義規則
- 9. ThinkPHP Validate自定義規則
- 10. 自定義StyleCop規則