diff --git a/lib/kaffe/consumer.ex b/lib/kaffe/consumer.ex index 57f591b..030399d 100644 --- a/lib/kaffe/consumer.ex +++ b/lib/kaffe/consumer.ex @@ -15,8 +15,8 @@ defmodule Kaffe.Consumer do @behaviour :brod_group_subscriber - @kafka Application.get_env(:kaffe, :kafka_mod, :brod) - @group_subscriber Application.get_env(:kaffe, :group_subscriber_mod, :brod_group_subscriber) + @kafka Application.compile_env(:kaffe, :kafka_mod, :brod) + @group_subscriber Application.compile_env(:kaffe, :group_subscriber_mod, :brod_group_subscriber) require Record import Record, only: [defrecord: 2, extract: 2] diff --git a/lib/kaffe/producer.ex b/lib/kaffe/producer.ex index 22d6657..9a486d3 100644 --- a/lib/kaffe/producer.ex +++ b/lib/kaffe/producer.ex @@ -19,7 +19,7 @@ defmodule Kaffe.Producer do Currently only synchronous production is supported. """ - @kafka Application.get_env(:kaffe, :kafka_mod, :brod) + @kafka Application.compile_env(:kaffe, :kafka_mod, :brod) @typedoc """ A Kafka message can be represented as a tuple containing a key value pair of type binary() diff --git a/test/support/test_brod.ex b/test/support/test_brod.ex index a051664..5c40a54 100644 --- a/test/support/test_brod.ex +++ b/test/support/test_brod.ex @@ -1,7 +1,7 @@ defmodule TestBrod do use GenServer - @test_partition_count Application.get_env(:kaffe, :test_partition_count) + @test_partition_count Application.compile_env(:kaffe, :test_partition_count) require Logger