kafak 默認的分區機制如何自定義分區機制

key值同樣的消息，發送同一個partitionpython ’partitioner’: DefaultPartitioner()web Record能夠只包含Topic和消息的value，key默認是None，可是大多數應用程序會用到key，key的兩個做用：算法 做爲消息的附加信息 決定消息該被寫到Topic的哪一個partition，擁有相同key的消息會被寫到同一個partition。

>>阅读原文<<