diff --git a/AWSKinesis/AWSAbstractKinesisRecorder.m b/AWSKinesis/AWSAbstractKinesisRecorder.m
index 17104007ebd..035a79c4fdf 100644
--- a/AWSKinesis/AWSAbstractKinesisRecorder.m
+++ b/AWSKinesis/AWSAbstractKinesisRecorder.m
@@ -255,7 +255,7 @@ - (AWSTask *)submitAllRecords {
                 while ([rs next]) {
                     [temporaryRecords addObject:@{
                                                   @"partition_key": [rs stringForColumn:@"partition_key"],
-                                                  @"data": [rs dataForColumn:@"data"],
+                                                  @"data": [rs dataForColumn:@"data"] ?: [NSNull null],
                                                   @"stream_name": [rs stringForColumn:@"stream_name"],
                                                   }];