private Consumer newConsumer(Topic topic, Properties common) {
            Properties properties = new Properties();
            properties.putAll(common);
            properties.put(ConsumerConfig.GROUP_ID_CONFIG, groupId(topic));
            return new Consumer(properties, topic.name);
        }
Called when a message is received.

@param topicPartition the topic partition of the received message
@param payload        the received message payload
@param sendTimeNanos  the time in nanoseconds when the message was sent
tools/src/main/java/org/apache/kafka/tools/automq/perf/ConsumerService.java