Skip to content

Instantly share code, notes, and snippets.

@moulishanmuhavelu
moulishanmuhavelu / KafkaRouteBuilder.java
Created March 8, 2020 06:44
Circuit breaker pattern in Kafka consumer
package com.example.camelkafkaconsumer.demo.route;
import java.util.ArrayList;
import java.util.List;
import org.apache.camel.Exchange;
import org.apache.camel.Predicate;
import org.apache.camel.builder.PredicateBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.kafka.KafkaConstants;