code: public static long generateConsumerGroupId(String flowId, String flowletId) {
      return Hashing.md5().newHasher()
                    .putString(flowId)
                    .putString(flowletId).hash().asLong();
    }
docs: Generates a queue consumer groupId for the given flowlet in the given program id.