メッセージレイヤの要件があり、消費者が消費されるまでメッセージの順序を保持したいと考えています。私たちはカフカを同じように探検しています。私はカフカがパーティション間の順序を保証するのではなく、パーティション内で順序を維持することを保証します。カフカのメッセージの順序を維持する方法は?
特定のプロデューサ(特定のキー値属性を持つ)がトピックt1の特定のパーティションp1にメッセージを発行し、コンシューマが同じパーティションp1からメッセージをフェッチすることを確認できるかどうかを確認することができたら、それは私たちの目的に役立ちます。 kafka-console-producer.sh
ヘルプの
、私は以下を参照:
--producer-property <producer_prop> A mechanism to pass user-defined
properties in the form key=value to
the producer.
--producer.config <config file> Producer config properties file. Note
that [producer-property] takes
precedence over this config.
--property <prop> A mechanism to pass user-defined
properties in the form key=value to
the message reader. This allows
custom configuration for a user-
defined message reader.
たちはプロデューサーがこの--property
オプションを使用して、への書き込みをされたパーティションを制御することはできますか?
また、上位レベルのコンシューマでは、消費するパーティションを制御できますか? パーティションはコンシューマにどのように割り当てられていますか?
パーティション内の順序を維持するために関連するイベントを生成する際に、一般的な 'key'を使用してください:http://stackoverflow.com/questions/29820384/apache-kafka-order-of-messages-with-multiple-partitions –