Связь между kinesis shardId и ключом раздела

Я создал поток кинезиса с 2 осколками.

Чтобы проверить связь ключей раздела с Shards, я использовал putRecord с ключом раздела равным 0 и текущим временем в миллисекундах и распечатал запись в потребительском приложении с помощью shardId. Но shardId не постоянен с ключом раздела.

Я имею в виду, что для 0 в качестве ключа раздела я вижу shardId 0 и 1, и тот же результат с ключом раздела, что и длинное число. Я новичок в кинезе,

Может кто-нибудь объяснить, почему shardId не является постоянным с ключом раздела?

0 ответов

Другие вопросы по тегам