Packages

kafe

2.1.6
2.2.3 2.2.1 2.2.0 2.1.7 2.1.6 2.1.5 2.1.4 2.1.3 2.1.2 2.1.1 2.1.0 2.0.0 1.6.2 1.6.1 1.6.0 1.5.1 1.5.0

A Kafka client for Erlang and Elixir

Current section

17 Versions

Jump to
Readme
17 Versions
6 Dependencies
Dependants
Files
Activity
Hide whitespace

Compare versions

4 files changed
+7 additions
-7 deletions
  @@ -1,5 +1,5 @@
1 1 {<<"name">>,<<"kafe">>}.
2 - {<<"version">>,<<"2.1.5">>}.
2 + {<<"version">>,<<"2.1.6">>}.
3 3 {<<"requirements">>,
4 4 #{<<"bristow">> => #{<<"app">> => <<"bristow">>,
5 5 <<"optional">> => false,
  @@ -4,7 +4,7 @@ defmodule Kafe.Mixfile do
4 4 def project do
5 5 [
6 6 app: :kafe,
7 - version: "2.1.5",
7 + version: "2.1.6",
8 8 elixir: "~> 1.2",
9 9 build_embedded: Mix.env == :prod,
10 10 start_permanent: Mix.env == :prod,
  @@ -1,6 +1,6 @@
1 1 {application,kafe,
2 2 [{description,"A Kafka client for Erlang and Elixir"},
3 - {vsn,"2.1.5"},
3 + {vsn,"2.1.6"},
4 4 {registered,[]},
5 5 {modules,[]},
6 6 {applications,[kernel,stdlib,syntax_tools,compiler,poolgirl,
  @@ -207,17 +207,17 @@ get_error_action(ErrorCode, ErrorsActions, Topic, Partition, Offset, GroupID) ->
207 207 {ok, Offset + 1};
208 208 {reset, earliest} ->
209 209 case get_partition_offset(Topic, Partition, -2) of
210 - {ok, _} = Offset1 ->
210 + {ok, Offset1} ->
211 211 commit(Offset1 - 1, Topic, Partition, GroupID),
212 - Offset1;
212 + {ok, Offset1};
213 213 _ ->
214 214 {error, internal_error}
215 215 end;
216 216 {reset, latest} ->
217 217 case get_partition_offset(Topic, Partition, -1) of
218 - {ok, _} = Offset1 ->
218 + {ok, Offset1} ->
219 219 commit(Offset1 - 1, Topic, Partition, GroupID),
220 - Offset1;
220 + {ok, Offset1};
221 221 _ ->
222 222 {error, internal_error}
223 223 end;