Support for Akka.Streams.Kafka?

[seungyongshim]

Hello~

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

@Aaronontheweb

[Aaronontheweb]

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]

@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