@Override
        public void receiveMessages(PeerInfo peerInfo, List<Message> messages) {
            if (messages != null && !messages.isEmpty()) {
                int msgCnt = messages.size();
                Message message = messages.get(0);
                TOTAL_COUNTER.addAndGet(msgCnt);
                AtomicLong accCount = TOPIC_COUNT_MAP.get(message.getTopic());
                accCount.addAndGet(msgCnt);
            }
        }
Initializes the TubeMQ consumer client(s) with the specified requirements.
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/CliConsumer.java