Apache Camel

What it is

Apache Camel is a versatile open-source integration framework that provides routing and mediation rules for connecting different systems. It implements Enterprise Integration Patterns (EIPs) and supports hundreds of components for various protocols and data formats.

Camel allows you to define routes using Java DSL, XML DSL, or Spring Boot integration. It supports message transformation, filtering, aggregation, and protocol bridging, including HTTP, JMS, Kafka, File, and more.

Installation

<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-core</artifactId>
  <version>3.23.0</version>
</dependency>

Getting started

The smallest useful thing you can do with it, and what each part means.

Simple route from file to console

java

1234567891011121314import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;

CamelContext context = new DefaultCamelContext();
context.addRoutes(new RouteBuilder() {
    @Override
    public void configure() {
        from("file:input").to("stream:out");
    }
});
context.start();
Thread.sleep(5000);
context.stop();

Reads files from the 'input' directory and prints their contents to the console.

HTTP to file route

java

from("jetty:http://0.0.0.0:8080/hello")
    .to("file:output");

Accepts HTTP requests and writes request bodies to files.

Advanced usage

Where the library earns its place over a simpler alternative.

Using processors for custom transformations

java

123456from("file:input")
    .process(exchange -> {
        String body = exchange.getIn().getBody(String.class);
        exchange.getMessage().setBody(body.toUpperCase());
    })
    .to("file:output");

Applies custom transformation logic using a Processor before sending messages.

Routing with conditions

java

1234from("file:input")
    .choice()
        .when(header("CamelFileName").endsWith(".txt")).to("file:txtOutput")
        .otherwise().to("file:otherOutput");

Routes files to different destinations based on file extension using content-based routing.

Integration with Kafka

java

from("kafka:my-topic?brokers=localhost:9092")
    .to("file:output");

Consumes messages from a Kafka topic and writes them to a file.

Error handling

java

onException(Exception.class)
    .handled(true)
    .log("Error occurred: ${exception.message}");

Handles exceptions in routes and logs the error message without stopping the route.

Errors and fixes

The failures you are most likely to hit, and what actually resolves them.

org.apache.camel.CamelExecutionException: Occurs when a route fails during execution. Check route configuration, endpoints, and processors.
Connection refused: Ensure target systems (HTTP, JMS, Kafka, etc.) are reachable and listening on correct ports.
FileNotFoundException: Verify source and destination directories exist and have proper permissions.

Best practices

Use Camel components appropriate for your protocols and systems.
Define routes using Java DSL for easier IDE support and refactoring.
Apply content-based routing and filtering for clean message flows.
Leverage error handling and dead-letter channels for robust integration.
Monitor routes using JMX or Camel’s management tools.

Background

Why it exists, and what it was reacting to.

Apache Camel was created to simplify system integration by providing a standard way to define routes and transformations. Developers can use Camel to connect databases, message brokers, REST APIs, and other systems with minimal boilerplate, making it popular in enterprise applications.

Related libraries

Others in Developer Utilities for Java.

MapStruct

Lombok

SLF4J

Log4j2

Guava

Apache Commons Lang