Skip to content

Commit e1850ca

Browse files
committed
Add fake NO_TOPICS for MetadataRequest v0
1 parent 071e66b commit e1850ca

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

kafka/protocol/metadata.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -172,6 +172,7 @@ class MetadataRequest_v0(Request):
172172
('topics', Array(String('utf-8')))
173173
)
174174
ALL_TOPICS = [] # Empty Array (len 0) for topics returns all topics
175+
NO_TOPICS = [] # v0 does not support a 'no topics' request, so we'll just ask for ALL
175176

176177

177178
class MetadataRequest_v1(Request):

0 commit comments

Comments
 (0)