Таблица аренды KCL не создается в Dynamo-DB после подключения потребителя - PullRequest
0 голосов
/ 23 января 2020

У нас есть недавно созданный поток кинезиса, который вызывает приведенную ниже ошибку при попытке подключения через KCL в java, и поток доступен для записи записей на лету.

java. lang.RuntimeException: com.amazon aws .services.kinesis.clientlibrary.exceptions.internal.KinesisClientLibIOException: Shard [shardId-000000000000] не закрыт. Это может произойти, если мы создали список фрагментов во время выполнения операции повторного анализа.

На основе документации

В нем говорится, что рабочий создаст и используйте описать поток для создания записей аренды и таблицы.

Следовательно, попытался aws kinesis description-stream - stream-name-name-of-the-stream и выдает

{
    "StreamDescription": {
        "Shards": [
            {
                "ShardId": "shardId-000000000000",
                "HashKeyRange": {
                    "StartingHashKey": "0",
                    "EndingHashKey": "340282366920938463463374607431768211455"
                },
                "SequenceNumberRange": {
                    "StartingSequenceNumber": "49603537352759079517281897546367071275105924397167280130"
                }
            }
        ],
        "StreamARN": "arn:aws:kinesis:us-west-2****",
        "StreamName": "***",
        "StreamStatus": "ACTIVE",
        "RetentionPeriodHours": 24,
        "EnhancedMonitoring": [
            {
                "ShardLevelMetrics": []
            }
        ],
        "EncryptionType": "NONE",
        "KeyId": null,
        "StreamCreationTimestamp": 1579767966.0
    }
}

Однако таблица аренды в динамической БД в том же регионе отсутствует. Любые предложения могут быть полезны.

Заранее спасибо.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...