@@ -621,21 +621,21 @@ class JsonSerde:
621
621
622
622
# keep strings, else json
623
623
def serialize (self , key , value ):
624
- if isinstance (value , str ):
625
- return value . encode ( "utf-8" ) , 1
626
- elif isinstance (value , bytes ):
627
- return value , 3
624
+ if isinstance (value , bytes ):
625
+ return value , 1
626
+ elif isinstance (value , str ):
627
+ return value . encode ( "utf-8" ), 2
628
628
else :
629
- return json .dumps (value , sort_keys = True , separators = ("," , ":" )).encode ("utf-8" ), 2
629
+ return json .dumps (value , sort_keys = True , separators = ("," , ":" )).encode ("utf-8" ), 3
630
630
631
631
# reverse previous serialization
632
632
def deserialize (self , key , value , flag ):
633
633
if flag == 1 :
634
- return value . decode ( "utf-8" )
634
+ return value
635
635
elif flag == 2 :
636
- return json . loads ( value .decode ("utf-8" ) )
636
+ return value .decode ("utf-8" )
637
637
elif flag == 3 :
638
- return value
638
+ return json . loads ( value . decode ( "utf-8" ))
639
639
else :
640
640
raise Exception ("Unknown serialization format" )
641
641
0 commit comments