Как подключить Kinesis локальный поток в Java?
Я запустил локальный кинесис с помощью команды ниже
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);
}
}
Аналогичным образом я тоже пишу для чтения.