** parition是物理上的概念，每個(gè)topic包含一個(gè)或多個(gè)partition，創(chuàng)建topic時(shí)可指定parition數(shù)量。每個(gè)partition對(duì)應(yīng)于一個(gè)文件夾，該文件夾下存儲(chǔ)該partition的數(shù)據(jù)和索引文件**

Producer

** 負(fù)責(zé)發(fā)布消息到Kafka broker**

Consumer

** 消費(fèi)消息。每個(gè)consumer屬于一個(gè)特定的consuer group（可為每個(gè)consumer指定group name，若不指定group name則屬于默認(rèn)的group）。使用consumer high level API時(shí)，同一topic的一條消息只能被同一個(gè)consumer group內(nèi)的一個(gè)consumer消費(fèi)，但多個(gè)consumer group可同時(shí)消費(fèi)這一消息。**