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...