MIx format & fix dialyxir
MODIFY
.github/workflows/checks.yml
.github/workflows/checks.yml
@@ -116,6 +116,8 @@ jobs:
with:
elixir-version: ${{matrix.elixir}} # Define the elixir version [required]
otp-version: ${{matrix.erlang}} # Define the OTP version [required]
+ experimental-otp: true # More info https://github.com/actions/setup-elixir/issues/31
+
- name: Retrieve Mix Dependencies Cache
uses: actions/cache@v2
id: mix-cache # id to use in retrieve action

MODIFY
lib/kafka_ex.ex
lib/kafka_ex.ex
@@ -297,11 +297,12 @@ defmodule KafkaEx do
api_version = Keyword.get(opts, :api_version, 0)
# same for offset_commit_api_version
offset_commit_api_version = Keyword.get(opts, :offset_commit_api_version, 0)
+
# By default, it makes sense to synchronize the API version of the offset_commit and the offset_fetch
# operations, otherwise we might commit the offsets in zookeeper and read them from Kafka, meaning
# that the value would be incorrect.
- offset_fetch_api_version = Keyword.get(opts, :offset_fetch_api_version, offset_commit_api_version)
-
+ offset_fetch_api_version =
+ Keyword.get(opts, :offset_fetch_api_version, offset_commit_api_version)
retrieved_offset =
current_offset(

MIx format & fix dialyxir