static void reportRecordCount() {
        System.err.println("Processed a total of " + messageCount + " messages");
    }
Consumer that dumps messages to standard out.
tools/src/main/java/org/apache/kafka/tools/consumer/ConsoleConsumer.java