diff --git a/lib/kaffe/config/consumer.ex b/lib/kaffe/config/consumer.ex index dc2b636..82f4d3c 100644 --- a/lib/kaffe/config/consumer.ex +++ b/lib/kaffe/config/consumer.ex @@ -36,12 +36,12 @@ defmodule Kaffe.Config.Consumer do defp specify_wildcard_topics([], _), do: [] defp specify_wildcard_topics(topics, idx) do - metadata = :brod.get_metadata(endpoints(idx)) + metadata = :brod.get_metadata(endpoints(idx), :all, client_consumer_config(idx)) topic_names = metadata |> elem(1) |> Map.get(:topics) |> Enum.map(& &1[:name]) Enum.flat_map(topics, fn("*" <> topic_name_tail) -> Enum.filter(topic_names, &(String.ends_with?(&1, topic_name_tail))) - end) |> IO.inspect(label: "specify_wildcard_topics") + end) end def message_handler(idx), do: config_get!(idx, :message_handler)