findhotel / akka-stream-trace

dapper tracing implementation for akka-streams and akka-http using htrace and zipkin


Gitter Chat Maven Central

Htrace extension for akka http and akka streams


docker run -d -p 9411:9411 -p 9410:9410 openzipkin/zipkin

running the examples:

sbt examples/run

then choose 1 for http example or 2 for streaming example

The http example will bind to port 8080. point your browesr to localhost:8080/frontend in order to initiate a request.

Getting Started:

The main advantage of using this library is that it eliminates the need for manual calls for logs and lets you focus on the right things, when things break you will still have a clear view into your applications, you can always add anontations later.

add the dependecy:

resolvers +=  Resolver.sonatypeRepo("releases") //akka-stream-trace sources 
resolvers += "Apache OSS Snapshots" at "" // htrace sources
libraryDependencies += "net.findhotel" %% "akka-stream-trace" % "0.3"

The first part of integrating the library is adding a config file, here's a basic example:

  span.receiver.classes = org.apache.htrace.impl.ZipkinSpanReceiver
  sampler.classes = org.apache.htrace.core.AlwaysSampler
  zipkin.scribe.hostname = "localhost"

This example tells htrace to use the zipkin receiver, samples all traces and points htrace to localhost as the span server.

now we have to configure the actor system to use the tracing dispatcher

  implicit val as = ActorSystem()
  val set = ActorMaterializerSettings(as)
  //We want to use the tracing dispatcher
  implicit val met = ActorMaterializer(set)

if you are using akka-http you are done, if this is a akka-streams applications add this call before your call to run:

val s = StreamTracer.tracer.newScope("compute")
Source.fromIterator(() => (1 to 100).toIterator).runFold(0)(_ +_)

don't forget to close the scope after the call to run


this method is shown in here


Tracing akka streams (scalar 2017):

Tracing Akka Steams with htrach