PutRecordsRequestEntry entry = new PutRecordsRequestEntry();
entry.setPartitionKey(KEY);
entry.setData(VALUE.getBytes());
List<PutRecordsRequestEntry> entries = new ArrayList<PutRecordsRequestEntry>();
entries.add(entry);
PutRecordsRequest putRecordsRequest = new PutRecordsRequest();
putRecordsRequest.setStreamName(KINESIS-STREAM-NAME);
putRecordsRequest.setRecords(entries);
PutRecordsResult putRecordsResult = client.putRecords(putRecordsRequest);
|