Method OnConsumerAdd

phxqueue/comm/breakpoint.h:332–332

    virtual void OnReloadConsumerConfigSucc(const int topic_id, const bool consumer_conf_modified) {}

    virtual void OnConsumerAdd(const int topic_id, const proto::Addr &addr) {}
    virtual void OnConsumerRemove(const int topic_id, const proto::Addr &addr) {}
    virtual void OnConsumerChange(const int topic_id, const int nconsumer) {}