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);