unsubscribe

On 20/03/2023, 10:30, "Jan Baudisch (extern)" <jan.baudisch.ext...@bdess.com 
<mailto:jan.baudisch.ext...@bdess.com>> wrote:


CAUTION: This email originated from outside of the organization. Do not click 
links or open attachments unless you can confirm the sender and know the 
content is safe.






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
 
<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 <mailto:ja...@scholz.cz>>
Datum: Montag, 20. März 2023 um 10:23
An: users@kafka.apache.org <mailto:users@kafka.apache.org> 
<users@kafka.apache.org <mailto: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/ 
<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 <mailto: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
>
>
>



Reply via email to