Hello Jakub, thank you for you quick answer. We solved it by implementing a ConfigProvider, like described here:
https://docs.confluent.io/kafka-connectors/self-managed/userguide.html#configprovider-interface public class TracingConfigProvider implements ConfigProvider { @Override public void configure(Map<String, ?> map) { final JaegerTracer tracer = Configuration.fromEnv().getTracer(); GlobalTracer.registerIfAbsent(tracer); } @Override public ConfigData get(String s) { return null; } @Override public ConfigData get(String s, Set<String> set) { return null; } @Override public void close(){} } And setting these Environment Variables in Kafka Connect - CONNECT_CONFIG_PROVIDERS=tracing - CONNECT_CONFIG_PROVIDERS_TRACING_CLASS=org.example.TracingConfigProvider Best regards, Jan Von: Jakub Scholz <ja...@scholz.cz> Datum: Montag, 20. März 2023 um 10:23 An: users@kafka.apache.org <users@kafka.apache.org> Betreff: Re: Kafka Connect Startup Hook In Strimzi, we use a Java agent to register the tracer ( https://github.com/strimzi/strimzi-kafka-operator/tree/main/tracing-agent/ if you wanna check the source code). Jakub On Mon, Mar 20, 2023 at 9:18 AM Jan Baudisch (extern) < jan.baudisch.ext...@bdess.com> wrote: > Hello, > > can someone please give me a hint how to execute two lines of code upon > Kafka Connect Startup, like: > > final JaegerTracer tracer = Configuration.fromEnv().getTracer(); > GlobalTracer.register(tracer); > > I implemented using a custom (Fake-)Connector, but there is much overhead, > because you also need a Task, Config etc. > > Is there some simpler way, some kind of hook? > > Thanks in advance, > Jan > > >
