docs: public static StringConsumers buildConsumer(
              final String zookeeperConfig,//
              final String topic,//
              final String groupId,//
              final IMessageListener<String> listener, //
              final int threads) {
          Properties props = new Properties();
          props.put("zk.connect", zookeeperConfig);
          props.put("zk.sessiontimeout.ms", "30000");
          props.put("zk.connectiontimeout.ms", "30000");
  
          final String JAFKA_PREFIX = "jafka.";
          for (Map.Entry<Object, Object> e : System.getProperties().entrySet()) {
              String name = (String) e.getKey();
              if (name.startsWith(JAFKA_PREFIX)) {
                  props.put(name.substring(JAFKA_PREFIX.length()), (String) e.getValue());
              }
          }
          return buildConsumer(props, topic, groupId, listener, threads);
      }