Merge pull request #144 from aiven/hacka/fix-infinite-loop

bugfix: fix infinite loop
Aiven-Open · Jan 20, 2021 · 4d95248 · 4d95248
2 parents 022063f + 4254119
commit 4d95248
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/karapace/kafka_rest_apis/admin.py b/karapace/kafka_rest_apis/admin.py
@@ -45,7 +45,7 @@ def cluster_metadata(self, topics: List[str] = None, retries: int = 0) -> dict:
                 "Kafka Admin interface cannot determine the controller using MetadataRequest_v{}.".format(metadata_version)
             )
         request = MetadataRequest[1](topics=topics)
-        future = self._send_request_to_node(self._client.least_loaded_node(), request)
+        future = self._send_request_to_least_loaded_node(request)
         try:
             self._wait_for_futures([future])
         except Cancelled:
@@ -94,7 +94,7 @@ def make_offsets_request(self, topic: str, partition_id: int, timestamp: int) ->
         else:
             request = OffsetRequest[2](-1, 1, list(six.iteritems({topic: [(partition_id, timestamp)]})))
 
-        future = self._send_request_to_node(self._client.least_loaded_node(), request)
+        future = self._send_request_to_least_loaded_node(request)
         return future
 
     def get_offsets(self, topic: str, partition_id: int) -> dict:

diff --git a/requirements-dev.txt b/requirements-dev.txt
@@ -1,5 +1,5 @@
 git+https://github.com/aiven/avro.git@skip-namespace-validation#subdirectory=lang/py3/
-git+git://github.com/aiven/kafka-python.git@346c01e4eec6bdcccc99ca613b79020f3be35eb7
+git+git://github.com/aiven/kafka-python.git@b9f2f78377d56392f61cba8856dc6c02ae841b79
 yapf==0.30.0
 aiohttp-socks==0.5.5
 pylint==2.4.4