[Chore] Fix a bug that when join_group is running, a new subscribed topic will be ignored

lmduc · lmduc · commit bb12e1188f0c · 2020-03-29T21:59:16.000+02:00
diff --git a/lib/kafka/consumer.rb b/lib/kafka/consumer.rb
@@ -472,6 +472,7 @@ def make_final_offsets_commit!(attempts = 3)
     end
 
     def join_group
+      @join_group_for_new_topics = false
       old_generation_id = @group.generation_id
 
       @group.join
