2016-09-27 55 views
1

我對Kinesis Streams相當陌生,花了很多時間閱讀文檔,但無法確定是否可能在單個分片上有多個「主題」(缺少更好的術語)。最初我以爲這是分區鍵的用途,但是reading thisAmazon Kinesis Streams - 每個分片有多個「主題」?

分區鍵用於按流中的分片分組數據。 Streams服務使用與每個數據記錄關聯的分區鍵來確定屬於某個流的數據記錄爲多個分片,以確定給定數據記錄屬於哪個分片。

...它聽起來像分區(可)跨越多個分片。

我目前不需要超過一個分片,但我需要能夠將消息分離到該分片內的不同通道/主題中 - 這對於Kinesis來說是不可能的嗎?

- 編輯 -

值得mentioning-我在我的應用程序同時使用KCL和KPL。

回答

1

只有一個分片,你將無法將你的數據分成單獨的頻道。要使用記錄,您必須首先調用GetShardIterator。 GetShardIterator獲取流名稱,分片ID和迭代器類型。

返回的分片迭代器是指向流的指針。如果您調用GetRecords並傳入分片迭代器,Kinesis會將記錄返回給您。響應將包含一批記錄,包括數據,時間戳,序列號和分區鍵。

今天調用GetRecords/GetShardIterator時無法指定主題或任何其他過濾器。

相關問題