public DeFiConsumerManager(final ConsumerIdsChangeListener consumerIdsChangeListener,
    final AdjustQueueNumStrategy strategy) {
    super(consumerIdsChangeListener);
    this.consumerIdsChangeListener = consumerIdsChangeListener;
    this.adjustQueueNumStrategy = strategy;

    try {
        this.consumerTable = (ConcurrentHashMap<String, ConsumerGroupInfo>) ReflectUtil.getSimpleProperty(ConsumerManager.class, this, "consumerTable");
    } catch (Exception ex) {
        log.warn("init DeFiConsumerManager err.", ex);
    }
}