Skip to content

Commit ff2f897

Browse files
committed
Fixup DeleteGroupsRequest new attr
1 parent c28567f commit ff2f897

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

kafka/admin/client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -504,7 +504,7 @@ def delete_topics(self, topics, timeout_ms=None, raise_errors=True):
504504
"""
505505
version = self._client.api_version(DeleteTopicsRequest, max_version=3)
506506
timeout_ms = self._validate_timeout(timeout_ms)
507-
request = DeleteTopicsRequest[version](topics=topics, timeout_ms=timeout_ms)
507+
request = DeleteTopicsRequest[version](topic_names=topics, timeout_ms=timeout_ms)
508508
def get_response_errors(r):
509509
for response in r.responses:
510510
yield Errors.for_code(response[1])

0 commit comments

Comments
 (0)