-
Notifications
You must be signed in to change notification settings - Fork 64
Open
Description
It is not possible for me to set auto_start_producers nor allow_topic_auto_creation via app-envs.
Suggested change:
diff --git a/lib/kaffe/config/consumer.ex b/lib/kaffe/config/consumer.ex
index 6e54e49..70b455c 100644
--- a/lib/kaffe/config/consumer.ex
+++ b/lib/kaffe/config/consumer.ex
@@ -93,8 +93,8 @@ defmodule Kaffe.Config.Consumer do
def default_client_consumer_config(config_key) do
[
- auto_start_producers: false,
- allow_topic_auto_creation: false,
+ auto_start_producers: config_get(config_key, :auto_start_producers, :false),
+ allow_topic_auto_creation: config_get(config_key, :allow_topic_auto_creation, :false),
begin_offset: begin_offset(config_key)
]
end
diff --git a/lib/kaffe/config/producer.ex b/lib/kaffe/config/producer.ex
index d2e09a1..dfca764 100644
--- a/lib/kaffe/config/producer.ex
+++ b/lib/kaffe/config/producer.ex
@@ -46,8 +46,8 @@ defmodule Kaffe.Config.Producer do
def default_client_producer_config do
[
- auto_start_producers: true,
- allow_topic_auto_creation: false,
+ auto_start_producers: config_get(:auto_start_producers, :true),
+ allow_topic_auto_creation: config_get(:allow_topic_auto_creation, :false),
default_producer_config: [
required_acks: config_get(:required_acks, -1),
ack_timeout: config_get(:ack_timeout, 1000),
Metadata
Metadata
Assignees
Labels
No labels