+ :param group_id: kafka group_id to use. Can be False (set group_id to None), None (use general group_id provided
+ at connect inside config), or a group_id string
+ :param from_beginning: if True, messages will be obtained from beginning instead of only new ones.
+ If group_id is supplied, only the not processed messages by other worker are obtained.
+ If group_id is None, all messages stored at kafka are obtained.