MINOR: Fix typo (#13044)

fix of Kakfa to Kafka

Reviewers: Luke Chen <showuon@gmail.com>
This commit is contained in:
Simon Woodman 2022-12-23 12:40:30 +00:00 committed by GitHub
parent 94c6d6488e
commit 5f265710f1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions

View File

@ -1425,7 +1425,7 @@ class KafkaService(KafkaPathResolverMixin, JmxMixin, Service):
self.logger.debug(output)
def search_data_files(self, topic, messages):
"""Check if a set of messages made it into the Kakfa data files. Note that
"""Check if a set of messages made it into the Kafka data files. Note that
this method takes no account of replication. It simply looks for the
payload in all the partition files of the specified topic. 'messages' should be
an array of numbers. The list of missing messages is returned.