UDPATE: privatize get_partitions()

stordco · Jan 9, 2025 · a08d625 · a08d625
1 parent 4cc9549
commit a08d625
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/kafee/consumer/brod_monitor.ex b/lib/kafee/consumer/brod_monitor.ex
@@ -82,7 +82,7 @@ defmodule Kafee.Consumer.BrodMonitor do
     :brod.fetch_committed_offsets(client_id, consumer_group_id)
   end
 
-  def get_partitions(endpoints, topic, options \\ []) do
+  defp get_partitions(endpoints, topic, options) do
     case :brod.get_metadata(endpoints, [topic], options) do
       {:ok, %{topics: [%{partitions: partitions}]}} ->
         Enum.map(partitions, fn %{partition_index: id} -> id end)
@@ -129,7 +129,7 @@ defmodule Kafee.Consumer.BrodMonitor do
     {:ok, lags_map}
   end
 
-  def committed_offsets_by_partition(committed_offsets) do
+  defp committed_offsets_by_partition(committed_offsets) do
     committed_offsets
     |> Enum.map(fn %{partition_index: partition, committed_offset: committed_offset} ->
       {partition, committed_offset}