code: async def xgroup_create(self, name: str, group: str, stream_id='$') -> bool:
          
          return await self.execute_command('XGROUP CREATE', name, group, stream_id)
docs: [NOTICE] Not officially released yet
          XGROUP is used in order to create, destroy and manage consumer groups.
          :param name: name of the stream
          :param group: name of the consumer group
          :param stream_id:
              If we provide $ as we did, then only new messages arriving
              in the stream from now on will be provided to the consumers in the group.
              If we specify 0 instead the consumer group will consume all the messages
              in the stream history to start with.
              Of course, you can specify any other valid ID