This is a Spring Boot AutoConfiguration module built into the Spark Streaming Job which fixes up spans reported by Finagle applications. Internally, this module wraps the FinagleAdjuster to expose configuration options via properties.
In order to connect, you minimally need to set
zipkin.sparkstreaming.adjuster.finagle.enabled to true.
Ex. to enable Finagle adjustment
java -jar zipkin-sparkstreaming-job.jar \
--zipkin.sparkstreaming.adjuster.finagle.enabled=true \
--zipkin.storage.type=elasticsearch \
--zipkin.storage.elasticsearch.hosts=http://127.0.0.1:9200 \
--zipkin.sparkstreaming.stream.kafka.bootstrap-servers=127.0.0.1:9092Configuration properties can be set via commandline parameters, system properties or any other alternative supported by Spring Boot.
Here are the relevant setting and a short description. Properties all have a prefix of "zipkin.sparkstreaming.adjuster.finagle"
| Property | Default | Description | Fix |
|---|---|---|---|
| apply-timestamp-and-duration | true | Backfill span.timestamp and duration based on annotations. | Use zipkin-finagle |
| adjust-issue343 | false | Drops "finagle.flush" annotation, to rectify finagle memcached bug. | Use finagle version 6.36.0 or higher |