chore(source): add a getter for Camel context
@@ -155,6 +155,10 @@ public class CamelSourceTask extends SourceTask {
}
}
+ protected CamelContext getContext() {
+ return camel;
+ }
+
private void setAdditionalHeaders(SourceRecord record, Map<String, Object> map, String prefix) {
for (Map.Entry<String, Object> entry : map.entrySet()) {
