Как подключить Kinesis локальный поток в Java? - PullRequest
Новая
       37

Как подключить Kinesis локальный поток в Java?

0 голосов
/ 29 ноября 2018

Я запустил kinesis local stream с помощью следующей команды 

kinesalite --port 4567

Но я не могу читать из потока или записывать в поток.

Вот мой код для написания: 

public static void writeToLocalStream(String message)
{

    String streamName="testStream";
    AWSCredentials credentials = new BasicAWSCredentials("TestAccessKey","TestSecretKey");
    AmazonKinesis kinesisClient = new AmazonKinesisClient(credentials);
    kinesisClient.setEndpoint("http://localhost:4567");
    System.out.println(kinesisClient.listStreams());
    byte[] bytes = message.getBytes();
    PutRecordRequest putRecord = new PutRecordRequest();
    putRecord.setStreamName(streamName);
    putRecord.setPartitionKey("needToBeUpdated");
    putRecord.setData(ByteBuffer.wrap(bytes));

    try {
        PutRecordResult putRecordsResult = kinesisClient.putRecord(putRecord);
        System.out.println("Put Result: " + putRecordsResult);
    } catch (AmazonClientException ex) {
        System.out.println("Error sending record to Amazon Kinesis. " + ex);
    }
}

Аналогичным образом, я также пишу для чтения.

...