@Override
    public void onPartitionsLost(Collection<TopicPartition> partitions) {
        Utils.printOut("Lost partitions: %s", partitions);
    }
This class implements a read-process-write application.
examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java