Correct spec & var names for KafkaEx.delete_topics
MODIFY
lib/kafka_ex.ex
lib/kafka_ex.ex
@@ -623,12 +623,12 @@ defmodule KafkaEx do
@doc """
Delete topics. Must provide a list of topic names.
"""
- @spec delete_topics([DeleteTopicsRequest.t()], Keyword.t()) ::
+ @spec delete_topics([String.t()], Keyword.t()) ::
DeleteTopicsResponse.t()
- def delete_topics(requests, opts \\ []) do
+ def delete_topics(topics, opts \\ []) do
worker_name = Keyword.get(opts, :worker_name, Config.default_worker())
timeout = Keyword.get(opts, :timeout)
- Server.call(worker_name, {:delete_topics, requests, timeout})
+ Server.call(worker_name, {:delete_topics, topics, timeout})
end
# OTP API

MODIFY
lib/kafka_ex/server.ex
lib/kafka_ex/server.ex
@@ -214,7 +214,7 @@ defmodule KafkaEx.Server do
) :: {:reply, reply, new_state}
when reply: term, new_state: term
@callback kafka_delete_topics(
- [DeleteTopicsRequest.t()],
+ [String.t()],
network_timeout :: integer,
state :: State.t()
) :: {:reply, reply, new_state}

Correct spec & var names for KafkaEx.delete_topics