Use global default timeout for delete_topics and create_topics
MODIFY
lib/kafka_ex.ex
lib/kafka_ex.ex
@@ -616,7 +616,7 @@ defmodule KafkaEx do
CreateTopicsResponse.t()
def create_topics(requests, opts \\ []) do
worker_name = Keyword.get(opts, :worker_name, Config.default_worker())
- timeout = Keyword.get(opts, :timeout, 4000)
+ timeout = Keyword.get(opts, :timeout)
Server.call(worker_name, {:create_topics, requests, timeout})
end
@@ -627,7 +627,7 @@ defmodule KafkaEx do
DeleteTopicsResponse.t()
def delete_topics(requests, opts \\ []) do
worker_name = Keyword.get(opts, :worker_name, Config.default_worker())
- timeout = Keyword.get(opts, :timeout, 4000)
+ timeout = Keyword.get(opts, :timeout)
Server.call(worker_name, {:delete_topics, requests, timeout})
end

MODIFY
lib/kafka_ex/server_0_p_10_and_later.ex
lib/kafka_ex/server_0_p_10_and_later.ex
@@ -196,7 +196,7 @@ defmodule KafkaEx.Server0P10AndLater do
@client_id,
%DeleteTopics.Request{
topics: topics,
- timeout: network_timeout
+ timeout: config_sync_timeout(network_timeout)
},
api_version
)
@@ -239,7 +239,7 @@ defmodule KafkaEx.Server0P10AndLater do
create_topics_request = %CreateTopics.Request{
create_topic_requests: requests,
- timeout: network_timeout
+ timeout: config_sync_timeout(network_timeout)
}
main_request =

Use global default timeout for delete_topics and create_topics