diff --git a/lib/kaffe/consumer_group/group_manager.ex b/lib/kaffe/consumer_group/group_manager.ex
index 648dad8..eed7dd9 100644
--- 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
index 7d0eadf..bf7158d 100644
--- 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
 
   ## ==========================================================================