Running ProcessingApp

In the last recipe, the Writer class was coded. Now, in this recipe everything is compiled and executed.

Getting ready

The execution of the previous recipes in this chapter is needed.

How to do it...

The ProcessingApp class coordinates the Reader and Writer classes. It contains the main method to execute them. Create a new file called src/main/java/doubloon/ProcessingApp.java and fill it with the following code:

package doubloon;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;

public class ProcessingApp {

    public static void main(String[] args) {
        String servers = args[0];
        String groupId = args[1];
        String sourceTopic = args[2];
        String targetTopic = args[3];

        Reader reader = new Reader(servers, groupId, sourceTopic);
        Writer writer = new Writer(servers, targetTopic);

        while (true) { // 1
            ConsumerRecords<String, String> consumeRecords...