chore: upgrade opentelemetry example to camel-opentelemetry2

Croway · Croway · commit 69cd0ee7188c · 2026-04-10T16:54:49.000+02:00
Migrate the opentelemetry example from the deprecated
camel-opentelemetry to camel-opentelemetry2.

Changes:
- Replace camel-opentelemetry-starter with camel-opentelemetry2-starter
- Replace @CamelOpenTelemetry with @CamelOpenTelemetry2
- Fix Kafka broker URLs for host-to-Docker connectivity
- Remove stale/unused properties (opentracing, jaeger, etc.)

Note: the async (Kafka) trace context propagation is currently broken
in camel-opentelemetry2 due to a missing byte[] header handling in
camel-telemetry's AbstractMessagingSpanDecorator. A fix has been
proposed in Apache Camel.
diff --git a/opentelemetry/CarBooking/pom.xml b/opentelemetry/CarBooking/pom.xml
@@ -32,7 +32,6 @@
     <description>An example showing how to use Camel with OpenTelemetry</description>
 
     <properties>
-        <io.opentracing.contrib.version>3.3.1</io.opentracing.contrib.version>
         <opentelemetry-agent.version>1.25.1</opentelemetry-agent.version>
     </properties>
 
@@ -88,7 +87,7 @@
         </dependency>
         <dependency>
             <groupId>org.apache.camel.springboot</groupId>
-            <artifactId>camel-jackson3-starter</artifactId>
+            <artifactId>camel-jackson3-starter</artifactId>
         </dependency>
         <dependency>
             <groupId>org.apache.camel.springboot</groupId>
@@ -119,7 +118,7 @@
         <!-- OpenTelemetry -->
         <dependency>
             <groupId>org.apache.camel.springboot</groupId>
-            <artifactId>camel-opentelemetry-starter</artifactId>
+            <artifactId>camel-opentelemetry2-starter</artifactId>
 
         </dependency>
 
@@ -168,4 +167,4 @@
             </plugin>
         </plugins>
     </build>
-</project>
+</project>
diff --git a/opentelemetry/CarBooking/src/main/java/com/example/demo/DemoApplication.java b/opentelemetry/CarBooking/src/main/java/com/example/demo/DemoApplication.java
@@ -16,11 +16,11 @@
  */
 package com.example.demo;
 
-import org.apache.camel.opentelemetry.starter.CamelOpenTelemetry;
+import org.apache.camel.opentelemetry2.starter.CamelOpenTelemetry2;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
-@CamelOpenTelemetry
+@CamelOpenTelemetry2
 @SpringBootApplication
 public class DemoApplication {
 
diff --git a/opentelemetry/CarBooking/src/main/java/com/example/demo/MySimpleCamelRouter.java b/opentelemetry/CarBooking/src/main/java/com/example/demo/MySimpleCamelRouter.java
@@ -39,10 +39,10 @@ public void configure() throws Exception {
                 .unmarshal().json(JsonLibrary.Jackson);
 
         // kafka based 
-        from("kafka:car_input?brokers=kafka:9092").routeId("bookCar-kafka")
+        from("kafka:car_input?brokers=localhost:9092").routeId("bookCar-kafka")
                 .log(LoggingLevel.INFO, "New book car request via Kafka topic")
                 .bean(new AvailableCars(),"getAvailableCar")
-                .to("kafka:car_output?brokers=kafka:9092");
+                .to("kafka:car_output?brokers=localhost:9092");
 
     }
 }
diff --git a/opentelemetry/FlightBooking/pom.xml b/opentelemetry/FlightBooking/pom.xml
@@ -31,10 +31,6 @@
 	<description>An example showing how to use Camel with OpenTelemetry</description>
 
 	<properties>
-		<java.version>11</java.version>
-		<camel.version>3.14.1</camel.version>
-		<jaeger.version>1.6.0</jaeger.version>
-		<io.opentracing.contrib.version>3.3.1</io.opentracing.contrib.version>
 		<opentelemetry-agent.version>1.25.1</opentelemetry-agent.version>
 	</properties>
 
@@ -87,7 +83,7 @@
 		</dependency>
 		<dependency>
 			<groupId>org.apache.camel.springboot</groupId>
-			<artifactId>camel-jackson3-starter</artifactId>
+			<artifactId>camel-jackson3-starter</artifactId>
 		</dependency>
 		<dependency>
 			<groupId>org.apache.camel.springboot</groupId>
@@ -113,7 +109,7 @@
 		<!-- OpenTelemetry -->
 		<dependency>
 			<groupId>org.apache.camel.springboot</groupId>
-			<artifactId>camel-opentelemetry-starter</artifactId>
+			<artifactId>camel-opentelemetry2-starter</artifactId>
 		</dependency>
 
 		<!-- Testing -->
diff --git a/opentelemetry/FlightBooking/src/main/java/com/example/demo/DemoApplication.java b/opentelemetry/FlightBooking/src/main/java/com/example/demo/DemoApplication.java
@@ -16,11 +16,11 @@
  */
 package com.example.demo;
 
+import org.apache.camel.opentelemetry2.starter.CamelOpenTelemetry2;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.apache.camel.opentelemetry.starter.CamelOpenTelemetry;
 
-@CamelOpenTelemetry
+@CamelOpenTelemetry2
 @SpringBootApplication
 public class DemoApplication {
 
diff --git a/opentelemetry/FlightBooking/src/main/java/com/example/demo/MySimpleCamelRouter.java b/opentelemetry/FlightBooking/src/main/java/com/example/demo/MySimpleCamelRouter.java
@@ -40,10 +40,10 @@ public void configure() throws Exception {
                 .unmarshal().json(JsonLibrary.Jackson);
 
         // kafka based 
-        from("kafka:flight_input?brokers=kafka:9092").routeId("bookFlight-kafka")
+        from("kafka:flight_input?brokers=localhost:9092").routeId("bookFlight-kafka")
                 .log(LoggingLevel.INFO, "New book flight request via Kafka topic")
                 .bean(new AvailableFlights(),"getAvailableFlight")
-                .to("kafka:flight_output?brokers=kafka:9092");
+                .to("kafka:flight_output?brokers=localhost:9092");
 
     }
 }
diff --git a/opentelemetry/HotelBooking/pom.xml b/opentelemetry/HotelBooking/pom.xml
@@ -32,7 +32,6 @@
 	<description>An example showing how to use Camel with OpenTelemetry</description>
 
 	<properties>
-		<io.opentracing.contrib.version>3.3.1</io.opentracing.contrib.version>
 		<opentelemetry-agent.version>1.25.1</opentelemetry-agent.version>
 	</properties>
 
@@ -85,7 +84,7 @@
 		</dependency>
 		<dependency>
 			<groupId>org.apache.camel.springboot</groupId>
-			<artifactId>camel-jackson3-starter</artifactId>
+			<artifactId>camel-jackson3-starter</artifactId>
 		</dependency>
 		<dependency>
 			<groupId>org.apache.camel.springboot</groupId>
@@ -111,7 +110,7 @@
 		<!-- OpenTelemetry -->
 		<dependency>
 			<groupId>org.apache.camel.springboot</groupId>
-			<artifactId>camel-opentelemetry-starter</artifactId>
+			<artifactId>camel-opentelemetry2-starter</artifactId>
 		</dependency>
 
 		<!-- Testing -->
diff --git a/opentelemetry/HotelBooking/src/main/java/com/example/demo/DemoApplication.java b/opentelemetry/HotelBooking/src/main/java/com/example/demo/DemoApplication.java
@@ -16,11 +16,11 @@
  */
 package com.example.demo;
 
+import org.apache.camel.opentelemetry2.starter.CamelOpenTelemetry2;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.apache.camel.opentelemetry.starter.CamelOpenTelemetry;
 
-@CamelOpenTelemetry
+@CamelOpenTelemetry2
 @SpringBootApplication
 public class DemoApplication {
 
diff --git a/opentelemetry/HotelBooking/src/main/java/com/example/demo/MySimpleCamelRouter.java b/opentelemetry/HotelBooking/src/main/java/com/example/demo/MySimpleCamelRouter.java
@@ -39,9 +39,9 @@ public void configure() throws Exception {
                 .unmarshal().json(JsonLibrary.Jackson);
 
         // kafka based 
-        from("kafka:hotel_input?brokers=kafka:9092").routeId("bookHotel-kafka")
+        from("kafka:hotel_input?brokers=localhost:9092").routeId("bookHotel-kafka")
                 .log(LoggingLevel.INFO, "New book hotel request via Kafka topic")
                 .bean(new AvailableHotels(),"getAvailableHotel")
-                .to("kafka:hotel_output?brokers=kafka:9092");
+                .to("kafka:hotel_output?brokers=localhost:9092");
     }
 }
diff --git a/opentelemetry/TripBooking/pom.xml b/opentelemetry/TripBooking/pom.xml
@@ -32,7 +32,6 @@
 	<description>An example showing how to use Camel with OpenTelemetry</description>
 
 	<properties>
-		<io.opentracing.contrib.version>3.3.1</io.opentracing.contrib.version>
 		<opentelemetry-agent.version>1.25.1</opentelemetry-agent.version>
 	</properties>
 
@@ -81,7 +80,7 @@
 		</dependency>
 		<dependency>
 			<groupId>org.apache.camel.springboot</groupId>
-			<artifactId>camel-jackson3-starter</artifactId>
+			<artifactId>camel-jackson3-starter</artifactId>
 		</dependency>
 		<dependency>
 			<groupId>org.apache.camel.springboot</groupId>
@@ -111,7 +110,7 @@
 		<!-- OpenTelemetry -->
 		<dependency>
 			<groupId>org.apache.camel.springboot</groupId>
-			<artifactId>camel-opentelemetry-starter</artifactId>
+			<artifactId>camel-opentelemetry2-starter</artifactId>
 		</dependency>
 
 		<!-- Testing -->
diff --git a/opentelemetry/TripBooking/src/main/java/com/example/demo/DemoApplication.java b/opentelemetry/TripBooking/src/main/java/com/example/demo/DemoApplication.java
@@ -16,11 +16,11 @@
  */
 package com.example.demo;
 
+import org.apache.camel.opentelemetry2.starter.CamelOpenTelemetry2;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.apache.camel.opentelemetry.starter.CamelOpenTelemetry;
 
-@CamelOpenTelemetry
+@CamelOpenTelemetry2
 @SpringBootApplication
 public class DemoApplication {
 
diff --git a/opentelemetry/TripBooking/src/main/java/com/example/demo/MySimpleCamelRouter.java b/opentelemetry/TripBooking/src/main/java/com/example/demo/MySimpleCamelRouter.java
@@ -54,14 +54,14 @@ public void configure() throws Exception {
                 // .to("log:debug?showAll=true&multiline=true")
                 .setBody(simple("New async request ${header.x-b3-traceid}"))
                 .multicast().parallelProcessing()
-                        .to("kafka:car_input?brokers=kafka:9092")
-                        .to("kafka:flight_input?brokers=kafka:9092")
-                        .to("kafka:hotel_input?brokers=kafka:9092")
+                        .to("kafka:car_input?brokers=localhost:9092")
+                        .to("kafka:flight_input?brokers=localhost:9092")
+                        .to("kafka:hotel_input?brokers=localhost:9092")
                 .end();
         
-        from("kafka:car_output?brokers=kafka:9092").to("seda:tripAggregator");
-        from("kafka:flight_output?brokers=kafka:9092").to("seda:tripAggregator");
-        from("kafka:hotel_output?brokers=kafka:9092").to("seda:tripAggregator");
+        from("kafka:car_output?brokers=localhost:9092").to("seda:tripAggregator");
+        from("kafka:flight_output?brokers=localhost:9092").to("seda:tripAggregator");
+        from("kafka:hotel_output?brokers=localhost:9092").to("seda:tripAggregator");
         
         from("seda:tripAggregator").routeId("bookTrip-kafka-response")
                 .aggregate(constant(true), new MergeAggregationStrategy())
diff --git a/opentelemetry/containers/compose.yaml b/opentelemetry/containers/compose.yaml
@@ -20,7 +20,9 @@ services:
     environment:
       - KAFKA_BROKER_ID=1
       - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
-      - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092
+      - KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
+      - KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:29092,PLAINTEXT_HOST://0.0.0.0:9092
+      - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092
       - KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1
   jaeger:
     image: jaegertracing/all-in-one:1.25

Original file line number	Diff line number	Diff line change
`@@ -39,10 +39,10 @@ public void configure() throws Exception {`
`39`	`39`	`.unmarshal().json(JsonLibrary.Jackson);`
`40`	`40`
`41`	`41`	`// kafka based`
`42`		`- from("kafka:car_input?brokers=kafka:9092").routeId("bookCar-kafka")`
	`42`	`+ from("kafka:car_input?brokers=localhost:9092").routeId("bookCar-kafka")`
`43`	`43`	`.log(LoggingLevel.INFO, "New book car request via Kafka topic")`
`44`	`44`	`.bean(new AvailableCars(),"getAvailableCar")`
`45`		`- .to("kafka:car_output?brokers=kafka:9092");`
	`45`	`+ .to("kafka:car_output?brokers=localhost:9092");`
`46`	`46`
`47`	`47`	`}`
`48`	`48`	`}`
Original file line number	Diff line number	Diff line change
`@@ -40,10 +40,10 @@ public void configure() throws Exception {`
`40`	`40`	`.unmarshal().json(JsonLibrary.Jackson);`
`41`	`41`
`42`	`42`	`// kafka based`
`43`		`- from("kafka:flight_input?brokers=kafka:9092").routeId("bookFlight-kafka")`
	`43`	`+ from("kafka:flight_input?brokers=localhost:9092").routeId("bookFlight-kafka")`
`44`	`44`	`.log(LoggingLevel.INFO, "New book flight request via Kafka topic")`
`45`	`45`	`.bean(new AvailableFlights(),"getAvailableFlight")`
`46`		`- .to("kafka:flight_output?brokers=kafka:9092");`
	`46`	`+ .to("kafka:flight_output?brokers=localhost:9092");`
`47`	`47`
`48`	`48`	`}`
`49`	`49`	`}`
Original file line number	Diff line number	Diff line change
`@@ -39,9 +39,9 @@ public void configure() throws Exception {`
`39`	`39`	`.unmarshal().json(JsonLibrary.Jackson);`
`40`	`40`
`41`	`41`	`// kafka based`
`42`		`- from("kafka:hotel_input?brokers=kafka:9092").routeId("bookHotel-kafka")`
	`42`	`+ from("kafka:hotel_input?brokers=localhost:9092").routeId("bookHotel-kafka")`
`43`	`43`	`.log(LoggingLevel.INFO, "New book hotel request via Kafka topic")`
`44`	`44`	`.bean(new AvailableHotels(),"getAvailableHotel")`
`45`		`- .to("kafka:hotel_output?brokers=kafka:9092");`
	`45`	`+ .to("kafka:hotel_output?brokers=localhost:9092");`
`46`	`46`	`}`
`47`	`47`	`}`