added support for earlier versions of camel-kafka

camel-kafka/build.gradle

@@ -24,5 +24,5 @@ jar {
 }
 
 verifyInstrumentation {
-    passes 'org.apache.camel:camel-kafka:[3.11.0,3.12.0)'
+    passes 'org.apache.camel:camel-kafka:(2.22.0,3.12.0)'
  }

camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java

@@ -0,0 +1,22 @@
+package org.apache.camel.component.kafka;
+
+import org.apache.camel.Exchange;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+
+import com.newrelic.api.agent.NewRelic;
+import com.newrelic.api.agent.TransportType;
+import com.newrelic.api.agent.weaver.Weave;
+import com.newrelic.api.agent.weaver.Weaver;
+import com.newrelic.instrumentation.camel.kafka.ConsumerRecordHeaders;
+
+@Weave
+public class KafkaConsumer {
+
+	@SuppressWarnings("unused")
+	private void propagateHeaders(ConsumerRecord<Object, Object> record, Exchange exchange,
+			KafkaConfiguration kafkaConfiguration) {
+		ConsumerRecordHeaders headers = new ConsumerRecordHeaders(record);
+		NewRelic.getAgent().getTransaction().acceptDistributedTraceHeaders(TransportType.Kafka, headers);
+		Weaver.callOriginal();
+	}
+}

settings.gradle

@@ -11,7 +11,7 @@ include 'camel-core-3.9'
 include 'camel-core-3.18'
 include 'camel-jms-3.18'
 include 'camel-core-4.0.0'
-include 'camel-core-4.1'
+include 'camel-core-4.1.0'
 include 'camel-jms-4.0.0'
 include 'camel-netty-3.0'
 include 'camel-netty-3.18'
@@ -20,3 +20,4 @@ include 'camel-kafka-3.14'
 include 'camel-kafka-3.15'
 include 'camel-kafka-3.18.3'
 include 'camel-processor'
+include 'camel-kafka'