2016-09-27 6 views
1

私はKinesis Streamsにはかなり新しく、ドキュメンテーションを通してたくさんの時間を費やしましたが、単一のシャード上に複数の「トピック」(より良い用語がないため)があるかどうかを判断できませんでした。パーティション・キーは、ストリーム内シャードによってグループデータに使用されているAmazon Kinesis Streams - シャードごとに複数の「トピック」?

:もともと私は、これはキーがしかしreading this後、ために何であったかのパーティションであると考えました。 Streamsサービスは、各データレコードに関連付けられたパーティションキーを使用して、ストリームに属するデータレコードを複数のシャードに分離して、特定のデータレコードが属するシャードを判別します。

...パーティション(缶)が複数のシャードにまたがるように私に聞こえます。私は現在、単一のシャードよりも多くを必要としませんが、私はそのshard-内の異なるチャネル/トピックにメッセージを分離することができるようにする必要性を行う

これはキネシスでは不可能でしょうか?

- EDIT - mentioning-は私のアプリケーションでKCLとKPLの両方を使用していフォートワース

答えて

1

1つのシャードだけでは、データを別々のチャンネルに分けることができません。レコードを消費するには、まずGetShardIteratorを呼び出す必要があります。 GetShardIteratorは、ストリーム名、シャードID、イテレータタイプを取ります。

返されるシャードイテレータは、ストリームへのポインタです。 KinesisはGetRecordsを呼び出すとレコードを返し、シャードイテレータを渡します。応答には、データ、タイムスタンプ、シーケンス番号、およびパーティションキーを含むレコードのバッチが含まれます。

今日、GetRecords/GetShardIteratorを呼び出すときに、トピックまたは他のフィルタを指定する方法はありません。

関連する問題