in src/main/java/com/amazon/kinesis/kafka/DataUtility.java [121:123]
public static Record createRecord(SinkRecord sinkRecord) { return new Record().withData(parseValue(sinkRecord.valueSchema(), sinkRecord.value())); }