Fix compile errors

spreedly · Feb 4, 2021 · c3c28a9 · c3c28a9
1 parent 3d50b44
commit c3c28a9
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/lib/kaffe/consumer_group/group_manager.ex b/lib/kaffe/consumer_group/group_manager.ex
@@ -173,7 +173,7 @@ defmodule Kaffe.GroupManager do
       state.consumer_group,
       state.worker_manager_pid,
       topic,
-      state.partitions_listener_pid,
+      state.partitions_listener_pid
     )
   end
 

diff --git a/lib/kaffe/consumer_group/subscriber/group_member.ex b/lib/kaffe/consumer_group/subscriber/group_member.ex
@@ -36,7 +36,8 @@ defmodule Kaffe.GroupMember do
               worker_manager_pid: nil,
               topic: nil,
               configured_offset: nil,
-              current_gen_id: nil
+              current_gen_id: nil,
+              partitions_listener_pid: nil
   end
 
   ## ==========================================================================