Skip to content

Commit feb3cae

Browse files
committed
Fixup fetch request forgotten_topics_data encoding
1 parent 6137aed commit feb3cae

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

kafka/protocol/fetch.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -287,7 +287,7 @@ class FetchRequest_v7(Request):
287287
('log_start_offset', Int64),
288288
('max_bytes', Int32))))),
289289
('forgotten_topics_data', Array(
290-
('topic', String),
290+
('topic', String('utf-8')),
291291
('partitions', Array(Int32))
292292
)),
293293
)
@@ -327,7 +327,7 @@ class FetchRequest_v9(Request):
327327
('log_start_offset', Int64),
328328
('max_bytes', Int32))))),
329329
('forgotten_topics_data', Array(
330-
('topic', String),
330+
('topic', String('utf-8')),
331331
('partitions', Array(Int32)),
332332
)),
333333
)
@@ -367,7 +367,7 @@ class FetchRequest_v11(Request):
367367
('log_start_offset', Int64),
368368
('max_bytes', Int32))))),
369369
('forgotten_topics_data', Array(
370-
('topic', String),
370+
('topic', String('utf-8')),
371371
('partitions', Array(Int32))
372372
)),
373373
('rack_id', String('utf-8')),

0 commit comments

Comments
 (0)