Merge pull request #133 from oyang/support_boto3_format_record

Boto3 client get_records return pure data
awslabs · Feb 3, 2021 · ab8d6ce · ab8d6ce
2 parents 0121e6c + 7692f3e
commit ab8d6ce
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/aws_kinesis_agg/deaggregator.py b/python/aws_kinesis_agg/deaggregator.py
@@ -219,7 +219,7 @@ def iter_deaggregate_records(records, data_format=None):
         # Decode the incoming data
         raw_data = r['kinesis']['data']
 
-        decoded_data = base64.b64decode(raw_data) #if data_format != 'Boto3' else raw_data
+        decoded_data = base64.b64decode(raw_data) if data_format != 'Boto3' else raw_data
 
         # Verify the magic header
         data_magic = None