@@ -26,14 +26,14 @@ def read_short_string(data, cur):
2626
2727 (strlen ,) = struct .unpack ('>h' , data [cur :cur + 2 ])
2828 if strlen == - 1 :
29- return ( None , cur + 2 )
29+ return None , cur + 2
3030
3131 cur += 2
3232 if len (data ) < cur + strlen :
3333 raise BufferUnderflowError ("Not enough data left" )
3434
3535 out = data [cur :cur + strlen ]
36- return ( out , cur + strlen )
36+ return out , cur + strlen
3737
3838
3939def read_int_string (data , cur ):
@@ -43,14 +43,14 @@ def read_int_string(data, cur):
4343
4444 (strlen ,) = struct .unpack ('>i' , data [cur :cur + 4 ])
4545 if strlen == - 1 :
46- return ( None , cur + 4 )
46+ return None , cur + 4
4747
4848 cur += 4
4949 if len (data ) < cur + strlen :
5050 raise BufferUnderflowError ("Not enough data left" )
5151
5252 out = data [cur :cur + strlen ]
53- return ( out , cur + strlen )
53+ return out , cur + strlen
5454
5555
5656def relative_unpack (fmt , data , cur ):
@@ -59,7 +59,7 @@ def relative_unpack(fmt, data, cur):
5959 raise BufferUnderflowError ("Not enough data left" )
6060
6161 out = struct .unpack (fmt , data [cur :cur + size ])
62- return ( out , cur + size )
62+ return out , cur + size
6363
6464
6565def group_by_topic_and_partition (tuples ):
0 commit comments