radio042

onException(JsonValidationException.class) 
        .handled(true) 
        .setHeader(Exchange.HTTP_RESPONSE_CODE, constant(400)) 
        .to("kafka:error-topic?brokers=localhost:29092") 
        .setBody().constant("Invalid json data"); 
 
from("rest:post:booking") 
        .to("json-validator:ui-schema.json") 
        .to("kafka:bookings?brokers=localhost:29092") 
        .setBody().constant("OK"); 

radio042

from("rest:post:booking") 
        .to("kafka:bookings?brokers=localhost:29092");

radio042

public class SimpleRoute extends RouteBuilder { 
    @Override 
    public void configure() { 
        // here 
    } 
} 

radio042

{ 
  "customerId": 6, 
  "providerId": 28, 
  "bicycleId": 496, 
  "fromDate": "2022-03-14", 
  "toDate": "2022-03-14" 
} 

radio042

package org.sharedpool;

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.spi.Registry;
import org.apache.camel.spi.TransactedPolicy;
import org.apache.camel.support.SimpleRegistry;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Test;