def METHOD_NAME(qualified_offset):
    qualified_offset_attributes = json.loads(qualified_offset)
    return nuclio_sdk.QualifiedOffset(
        topic=qualified_offset_attributes['topic'],
        partition=qualified_offset_attributes['partition'],
        offset=qualified_offset_attributes['offset']
    ), qualified_offset_attributes['body'].encode('utf-8')