У нас есть недавно созданный поток кинезиса, который вызывает приведенную ниже ошибку при попытке подключения через 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
}
}
Однако таблица аренды в динамической БД в том же регионе отсутствует. Любые предложения могут быть полезны.
Заранее спасибо.