code: def get_group_offsets(self, group, topic=None):
          
          group_offsets = {}
          try:
              all_topics = self.get_my_subscribed_topics(group)
          except NoNodeError:
              # No offset information of given consumer-group
              _log.warning(
                  "No topics subscribed to consumer-group {group}.".format(
                      group=group,
                  ),
              )
              return group_offsets
          if topic:
              if topic in all_topics:
                  topics = [topic]
              else:
                  _log.error(
                      "Topic {topic} not found in topic list {topics} for consumer"
                      "-group {consumer_group}.".format(
                          topic=topic,
                          topics=', '.join(topic for topic in all_topics),
                          consumer_group=group,
                      ),
                  )
                  return group_offsets
          else:
              topics = all_topics
          for topic in topics:
              group_offsets[topic] = {}
              try:
                  partitions = self.get_my_subscribed_partitions(group, topic)
              except NoNodeError:
                  _log.warning(
                      "No partition offsets found for topic {topic}. "
                      "Continuing to next one...".format(topic=topic),
                  )
                  continue
              # Fetch offsets for each partition
              for partition in partitions:
                  path = "/consumers/{group_id}/offsets/{topic}/{partition}".format(
                      group_id=group,
                      topic=topic,
                      partition=partition,
                  )
                  try:
                      # Get current offset
                      offset_json, _ = self.get(path)
                      group_offsets[topic][partition] = load_json(offset_json)
                  except NoNodeError:
                      _log.error("Path {path} not found".format(path=path))
                      raise
          return group_offsets
docs: Fetch group offsets for given topic and partition otherwise all topics
          and partitions otherwise.
  
  
          {
              'topic':
              {
                  'partition': offset-value,
                  ...
                  ...
              }
          }