fix ListOffsetsRequest_v4

dpkp · dpkp · commit 6a637e0a7da6 · 2025-03-05T08:04:02.000-08:00
diff --git a/kafka/protocol/list_offsets.py b/kafka/protocol/list_offsets.py
@@ -166,7 +166,7 @@ class ListOffsetsRequest_v4(Request):
             ('topic', String('utf-8')),
             ('partitions', Array(
                 ('partition', Int32),
-                ('current_leader_epoch', Int64),
+                ('current_leader_epoch', Int32),
                 ('timestamp', Int64)))))
     )
     DEFAULTS = {

Original file line number	Diff line number	Diff line change
`@@ -166,7 +166,7 @@ class ListOffsetsRequest_v4(Request):`
`166`	`166`	`('topic', String('utf-8')),`
`167`	`167`	`('partitions', Array(`
`168`	`168`	`('partition', Int32),`
`169`		`- ('current_leader_epoch', Int64),`
	`169`	`+ ('current_leader_epoch', Int32),`
`170`	`170`	`('timestamp', Int64)))))`
`171`	`171`	`)`
`172`	`172`	`DEFAULTS = {`