Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

working with kafka #114

Open
GabrielMller opened this issue Oct 18, 2023 · 5 comments
Open

working with kafka #114

GabrielMller opened this issue Oct 18, 2023 · 5 comments
Labels
enhancement New feature or request processor-support Relates to supporting various processors such as HTTP, DB, Kafka, Anypoint MQ etc in the module.

Comments

@GabrielMller
Copy link

Hi, I'm working with Kafka on Mulesoft, and I would like to pass the trace id from the publisher to the consumer, I tried to put a traceparent header, but the trace id did not propagate, is there already a way to do this or has it not been implemented yet?

@manikmagar
Copy link
Contributor

@GabrielMller As per specs, traceparent does include traceId. See details about traceparent here. It is used by the consumer to establish parent-child relationship of the distributed traces. If the consumer side is this module, then that relationship will be established but the module does not pass or extract traceId from that traceparent.

If you need to send traceId as a separate header then you can set it, just like traceparent. vars.OTEL_TRACE_CONTEXT.traceId can give you the current trace id for propagating. Documentation was missing the latest screenshot but #115 should correct that gap.

I hope that answers what you are looking for.

@GabrielMller
Copy link
Author

I need to propagate my trace from the application of the publisher, to the application consumer, i tried to pass a traceId header, but the otel connector dont get it.
image

@manikmagar
Copy link
Contributor

@GabrielMller Thanks for the clarification. You are looking to propagate the trace context across the Kafka connector. Unfortunately, that is not implemented yet and hence module is unable to identify context on the consumer side. Thanks for raising this though, we will plan to look into this.

@manikmagar manikmagar added enhancement New feature or request processor-support Relates to supporting various processors such as HTTP, DB, Kafka, Anypoint MQ etc in the module. labels Oct 18, 2023
@GabrielMller
Copy link
Author

Ok, thanks for your help!

@JYOTHI-SHRAVZ
Copy link

Hi ,is this implemented yet ? Or is there any plans to implement it in the near future?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request processor-support Relates to supporting various processors such as HTTP, DB, Kafka, Anypoint MQ etc in the module.
Projects
None yet
Development

No branches or pull requests

3 participants