Чтение данных из потока кинесиса AWS с помощью Java - PullRequest
Новая
       12

Чтение данных из потока кинесиса AWS с помощью Java

0 голосов
/ 18 июня 2019

Я хочу прочитать пример данных из AWS Kinesis с помощью Java / Spring.Я получил приведенный ниже код, пробовал, но получаю ошибку, что -

java.lang.NoSuchFieldError: SERVICE_ID

Пожалуйста, помогите или любым другим способом для чтения данных из AWS Kinesis тогдаПоделись со мной.Спасибо. 

DescribeStreamRequest describeStreamRequest = new DescribeStreamRequest();
describeStreamRequest.setStreamName( streamName );
List<Shard> shards = new ArrayList<>();
String exclusiveStartShardId = null;
do {
//  describeStreamRequest.setExclusiveStartShardId( exclusiveStartShardId );
//  AmazonKinesisClient client= new AmazonKinesisClient();
    DescribeStreamResult describeStreamResult = client.describeStream( describeStreamRequest );
    System.out.println("describeStreamResult ------- " + describeStreamResult);
    shards.addAll( describeStreamResult.getStreamDescription().getShards() );
    if (describeStreamResult.getStreamDescription().getHasMoreShards() && shards.size() > 0) {
        exclusiveStartShardId = shards.get(shards.size() - 1).getShardId();
        System.out.println( "---------- exclusiveStartShardId --- " + exclusiveStartShardId);
    } else {
        exclusiveStartShardId = null;
    }
} while ( exclusiveStartShardId != null );

08:40:50.539 [main] DEBUG com.amazonaws.metrics.AwsSdkMetrics - Admin mbean registered under com.amazonaws.management:type=AwsSdkMetrics
Exception in thread "main" java.lang.NoSuchFieldError: SERVICE_ID
    at com.amazonaws.services.kinesis.AmazonKinesisClient.executeDescribeStream(AmazonKinesisClient.java:861)
    at com.amazonaws.services.kinesis.AmazonKinesisClient.describeStream(AmazonKinesisClient.java:842)
...