Run "mix format" on the project
MODIFY
lib/kafka_ex/gen_consumer.ex
lib/kafka_ex/gen_consumer.ex
@@ -250,10 +250,13 @@ defmodule KafkaEx.GenConsumer do
Any other return value will cause the `start_link/5` to return `{:error,
error}` and the process to exit.
"""
- @callback init(topic :: binary, partition :: non_neg_integer, extra_args :: map()) ::
+ @callback init(
+ topic :: binary,
+ partition :: non_neg_integer,
+ extra_args :: map()
+ ) ::
{:ok, state :: term}
-
@doc """
Invoked for each message set consumed from a Kafka topic partition.
@@ -367,7 +370,11 @@ defmodule KafkaEx.GenConsumer do
{:noreply, consumer_state}
end
- defoverridable init: 2, init: 3, handle_call: 3, handle_cast: 2, handle_info: 2
+ defoverridable init: 2,
+ init: 3,
+ handle_call: 3,
+ handle_cast: 2,
+ handle_info: 2
end
end
@@ -524,7 +531,9 @@ defmodule KafkaEx.GenConsumer do
:extra_consumer_args
)
- {:ok, consumer_state} = consumer_module.init(topic, partition, extra_consumer_args)
+ {:ok, consumer_state} =
+ consumer_module.init(topic, partition, extra_consumer_args)
+
worker_opts = Keyword.take(opts, [:uris])
{:ok, worker_name} =

MODIFY
test/integration/server0_p_10_p_1_test.exs
test/integration/server0_p_10_p_1_test.exs
@@ -2,9 +2,10 @@ defmodule KafkaEx.Server0P10P1.Test do
use ExUnit.Case
@moduletag :server_0_p_10_and_later
- @moduletag :server_0_p_10_p_1
# specific to this server version because we want to test that the api_versions list is exact
+ @moduletag :server_0_p_10_p_1
+
@tag :api_version
test "can retrieve api versions" do
# api_key, max_version, min_version

MODIFY
test/protocol/join_group_test.exs
test/protocol/join_group_test.exs
@@ -3,8 +3,7 @@ defmodule KafkaEx.Protocol.JoinGroup.Test do
alias KafkaEx.Protocol.JoinGroup
test "create_request creates a valid join group request" do
- good_request =
- <<
+ good_request = <<
# Preamble
11::16,
0::16,

Run "mix format" on the project