From c3c28a99374dbfb1506627b7d2aa9c24a7f75c82 Mon Sep 17 00:00:00 2001 From: Harsha Vardhan Gelivi Date: Thu, 4 Feb 2021 17:24:58 +0530 Subject: [PATCH] Fix compile errors --- lib/kaffe/consumer_group/group_manager.ex | 2 +- lib/kaffe/consumer_group/subscriber/group_member.ex | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) 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 ## ==========================================================================