Run linter
This commit is contained in:
@@ -48,4 +48,3 @@ config :logger, level: :info
|
|||||||
# force_ssl: [hsts: true]
|
# force_ssl: [hsts: true]
|
||||||
#
|
#
|
||||||
# Check `Plug.SSL` for all available options in `force_ssl`.
|
# Check `Plug.SSL` for all available options in `force_ssl`.
|
||||||
|
|
||||||
|
|||||||
@@ -38,13 +38,13 @@ if config_env() == :prod do
|
|||||||
# See `mix help release` for more information.
|
# See `mix help release` for more information.
|
||||||
end
|
end
|
||||||
|
|
||||||
{port, _} = System.fetch_env!("KAFKA_BROKER_PORT")
|
{port, _} =
|
||||||
|> Integer.parse
|
System.fetch_env!("KAFKA_BROKER_PORT")
|
||||||
|
|> Integer.parse()
|
||||||
|
|
||||||
config :kafka_ex,
|
config :kafka_ex,
|
||||||
brokers: [
|
brokers: [
|
||||||
{System.fetch_env!("KAFKA_BROKER1_HOST"), port},
|
{System.fetch_env!("KAFKA_BROKER1_HOST"), port},
|
||||||
{System.fetch_env!("KAFKA_BROKER2_HOST"), port},
|
{System.fetch_env!("KAFKA_BROKER2_HOST"), port},
|
||||||
{System.fetch_env!("KAFKA_BROKER3_HOST"), port},
|
{System.fetch_env!("KAFKA_BROKER3_HOST"), port}
|
||||||
]
|
]
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user