code: def create_gzip_message(message_set):
      
      encoded_message_set = KafkaCodec._encode_message_set(message_set)
  
      gzipped = gzip_encode(encoded_message_set)
      return Message(0, CODEC_GZIP, None, gzipped)
docs: Construct a gzip-compressed message containing multiple messages
  
      The given messages will be encoded, compressed, and sent as a single atomic
      message to Kafka.
  
      :param list message_set: a list of :class:`Message` instances