Skip to content

Commit

Permalink
We need value to return
Browse files Browse the repository at this point in the history
  • Loading branch information
rewritten committed Jan 3, 2024
1 parent 3b7c317 commit e82455c
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions lib/broadway_kafka/brod_client.ex
Original file line number Diff line number Diff line change
Expand Up @@ -297,14 +297,14 @@ defmodule BroadwayKafka.BrodClient do
defp validate_option(:sasl, value = {:callback, _callback_module, _opts}),
do: {:ok, value}

defp validate_option(:sasl, {mechanism, username, password})
defp validate_option(:sasl, {mechanism, username, password} = value)
when mechanism in [:plain, :scram_sha_256, :scram_sha_512] and
is_binary(username) and
is_binary(password) do
{:ok, value}
end

defp validate_option(:sasl, {mechanism, path})
defp validate_option(:sasl, {mechanism, path} = value)
when mechanism in [:plain, :scram_sha_256, :scram_sha_512] and
is_binary(path) do
{:ok, value}
Expand Down

0 comments on commit e82455c

Please sign in to comment.