@@ -0,0 +1,1928 @@
+package kata.app;%0A%0Aimport com.fasterxml.jackson.core.JsonProcessingException;%0Aimport com.fasterxml.jackson.databind.ObjectMapper;%0Aimport org.apache.logging.log4j.Level;%0Aimport org.apache.logging.log4j.LogManager;%0Aimport org.apache.logging.log4j.Logger;%0Aimport org.apache.logging.log4j.simple.SimpleLogger;%0Aimport org.apache.logging.log4j.util.PropertiesUtil;%0Aimport org.bushe.swing.event.EventBus;%0Aimport org.bushe.swing.event.EventTopicSubscriber;%0A%0Aimport java.io.FileDescriptor;%0Aimport java.io.FileOutputStream;%0Aimport java.io.PrintStream;%0A%0Aimport static kata.app.CSVReader.TOPIC_CSV2JSON;%0A%0Apublic class JSONWriter implements EventTopicSubscriber %7B%0A%0A    PrintStream ps = new PrintStream(new FileOutputStream(FileDescriptor.out));%0A%0A    SimpleLogger logger = new SimpleLogger(%0A            JSONWriter.class.getName(), Level.DEBUG, true, true, true, true, %22HH:mm:ss.SSS%22, null, PropertiesUtil.getProperties(), ps);%0A%0A    private final ObjectMapper mapper = new ObjectMapper();%0A    private Person person;%0A%0A    public JSONWriter() %7B%0A        EventBus.subscribe(TOPIC_CSV2JSON, this);%0A    %7D%0A%0A    public void onEvent(final String topic, final Object payload) %7B%0A        if (TOPIC_CSV2JSON.equalsIgnoreCase(topic)) %7B%0A            String message = payload.toString();%0A%0A            String%5B%5D msg = message.split(%22,%22);%0A            try %7B%0A                switch (msg%5B0%5D) %7B%0A                    case %22first_name%22:%0A                        person = new Person(msg%5B1%5D);%0A                        break;%0A                    case %22last_name%22:%0A                        person.setLastName(msg%5B1%5D);%0A                        // Convert to JSON and display%0A                        logger.info(mapper.writeValueAsString(person));%0A                        break;%0A                    default:%0A                        break;%0A                %7D%0A            %7D catch (JsonProcessingException jpe) %7B%0A                jpe.printStackTrace();%0A            %7D%0A        %7D%0A    %7D%0A%7D%0A

Create JSONWriter.java