docs: @Override
      public UniversalKafkaQueue init() throws Exception {
          super.init();
  
          if (getMessageFactory() == null) {
              setMessageFactory(UniversalIdIntQueueMessageFactory.INSTANCE);
          }
  
          return this;
      }