Kafkaのキー/バリューペアベースのメッセージングの目的は何ですか？

Question

のすべてexamplesのKafka | producersは、ProducerRecordのキーと値のペアが同じタイプ（すべての例では<String,String>と表示されている）であるだけでなく、同じ値であることを示しています。たとえば：

producer.send(new ProducerRecord<String, String>("someTopic", Integer.toString(i), Integer.toString(i))); 

しかし、カフカのドキュメントでは、私はどこのキー/値の概念（およびその基礎となる目的/ユーティリティ）を見つけることができないように説明されています。伝統的なメッセージング（ActiveMQ、RabbitMQなど）では、私はいつも特定のトピック/キュー/エクスチェンジでメッセージを発しました。しかし、カフカは、レギュレーションの文字列メッセージの代わりにキー/値のペアを必要とする最初のブローカーです。

私は質問します：生産者にKVペアを送信する必要性の目的/有用性は何ですか？

Answer 1

カフカはパーティションで構成され、分散ログの抽象化を使用しています。ログを複数のパーティションに分割することで、システムをスケールアウトすることができます。

キーは、メッセージgetが追加されるログ内のパーティションを決定するために使用されます。値はメッセージの実際のペイロードです。この事例は実際にはあまり「良い」ものではありません。通常は複合型を値として（タプル型やJSONなど）、キーとして1つのフィールドを抽出します。

参照：http://kafka.apache.org/intro#intro_topicsとhttp://kafka.apache.org/intro#intro_producers

は、一般的には、キーおよび/または値があまりにも、nullすることができます。キーがnullの場合、ランダムなパーティションが選択されます。値がnullの場合、には、トピックのログ保持ポリシーの代わりにログ圧縮を有効にする場合（http://kafka.apache.org/documentation#compaction）、特別な「削除」セマンティクスがあります。