search

petabridge / phobos-issues

Public issues and bug tracker for Phobos®
https://phobos.petabridge.com/
2 stars 1 forks source link

Support for Akka.Streams.Kafka? #25

Open seungyongshim opened 3 years ago

seungyongshim commented 3 years ago

Hello~

Support to tracing with Phobos for Akka.Streams.Kafka?

@Aaronontheweb

Aaronontheweb commented 3 years ago

We have some support today based on the materialized actors, but we really need to include an end-to-end example on how to do this.

Going to add it to my to-do list - in particular, we need to propagate the tracing headers from Phobos over the wire on Kafka.

Arkatufus commented 3 years ago

@seungyongshim,

Sorry for the long delay. We're still working on a better implementation for this, but we do have a working sample that implements Phobos tracking and propagating it through Akka.Streams.Kafka. It is still a bit rough, it still need better documentation and polish to make it more automated, but you can use it as a base to write your implementation if you're in a rush.

You can check the code here: https://github.com/petabridge/Phobos.Samples