Camel Routes - Step 7

CamelRoutes.java

//...
from("kafka:input_topic?brokers=localhost:9092&groupId=group1")
    .unmarshal().json(UserMessage.class)
    .filter(simple("${body.type} == 'chat'"))
    .log("${body}")
    .split(simple("${body.devices}"))
        .log("${body}")
    .end()
    .marshal().json()
    .to("kafka:output_topic?brokers=localhost:9092")
    .to("direct:store_in_file");

from("direct:store_in_file")
    .unmarshal().json(UserMessage.class)
    .choice()
    .when(simple("${body.emitter} == 'John Doe'"))
        .marshal().json().to("file:///home/diogoferreira/Desktop/Apache Camel Demo/getting-started/user-message?filename=events.json&fileExist=Append&appendChars=\\n")
    .otherwise()
        .marshal().json().to("file:///home/diogoferreira/Desktop/Apache Camel Demo/getting-started/john-doe-message?filename=events.json&fileExist=Append&appendChars=\\n")
    .end();
//...