kafka分區介紹

kafka可以將一個topic(主題)從物理上分爲一個或多個區partition,每個分區在物理上對應一個文件夾,以」topicName_partitionIndex」的命名方式命名,該文件夾下存儲這個分區的所有消息(.log)和索引文件(.index),這使得Kafka的吞吐率可以水平擴展 生產者在生產數據的時候,可以爲每條消息指定Key,這樣消息被髮送到broker時,會根據分區規則選擇被存儲
相關文章
相關標籤/搜索