Skip to content

Commit

Permalink
Merge branch 'master' into multiconfig
Browse files Browse the repository at this point in the history
  • Loading branch information
romul authored Oct 17, 2023
2 parents e02aa1b + 8ab0225 commit 40082f4
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions lib/kaffe/consumer_group/group_manager.ex
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,7 @@ defmodule Kaffe.GroupManager do

state = %State{state | worker_manager_pid: worker_manager_pid}

subscribe_to_topics(state, state.topics)
:ok = subscribe_to_topics(state, state.topics)

{:noreply, state}
end
Expand All @@ -113,7 +113,7 @@ defmodule Kaffe.GroupManager do
"""
def handle_call({:subscribe_to_topics, requested_topics}, _from, %State{topics: topics} = state) do
new_topics = requested_topics -- topics
subscribe_to_topics(state, new_topics)
:ok = subscribe_to_topics(state, new_topics)

{:reply, {:ok, new_topics}, %State{state | topics: state.topics ++ new_topics}}
end
Expand Down
4 changes: 2 additions & 2 deletions mix.exs
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ defmodule Kaffe.Mixfile do
use Mix.Project

@source_url "https://github.com/spreedly/kaffe"
@version "1.23.0"
@version "1.24.0"

def project do
[
Expand Down Expand Up @@ -44,7 +44,7 @@ defmodule Kaffe.Mixfile do
"An opinionated Elixir wrapper around brod, the Erlang Kafka client, " <>
"that supports encrypted connections to Heroku Kafka out of the box.",
licenses: ["MIT"],
maintainers: ["Kevin Lewis", "David Santoso", "Ryan Daigle", "Spreedly", "Joe Peck", "Brittany Hayes"],
maintainers: ["Kevin Lewis", "David Santoso", "Ryan Daigle", "Spreedly", "Joe Peck", "Brittany Hayes", "Anthony Walker"],
links: %{
"GitHub" => @source_url
}
Expand Down

0 comments on commit 40082f4

Please sign in to comment.