Hi folks, apologies in advance if this is not the right place to ask this My team and I work on a data pipeline that is comprised of Flink microservices with Kafka as the message bus inbetween services, and we are looking into approaches for tracking the lifetime of events between services to enable latency analysis. What are some approaches folks have used to enable distributed trace methodologies? I know OTEL is a common use case, do folks have others they have found success with?

I think @Jaehyeon Kim built an example around this?

I’ve tried implementing data lineage but haven’t worked with traces. Flink’s documentation includes a section on traces. Do you have any specific requirements or use cases in mind?