zipkin-storage-kafka
zipkin-storage-kafka copied to clipboard
openzipkin-contrib
Kafka-based storage for Zipkin.
changes related to https://github.com/openzipkin-contrib/zipkin-storage-kafka/issues/71
Include a module to take incoming spans and serialize them in a format supported by Confluent Schema Registry (e.g. potentially Avro), to enable the Kafka ecosystem to consume tracing data...
## Feature: To provide a way to sample entire trace which contains span with specific tags such as "error=true" or significant delay ## Rational Currently sampling is based on traceId....
If `/storage/kafka` endpoint is not mounted properly, storage won't work--but tests will be green. We could test this via Docker Hub tests or Integration Test with TestContainers.
Not sure why this doesn't fail in travis. Maybe we need to guard stuff more specifically ``` java.util.concurrent.CompletionException: java.net.UnknownHostException: failed to resolve 'macbook-pro-7.local' after 3 queries at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:331) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:346)...
There seems to be a bug on how are we collecting service names, leading to duplicated results on the `getServiceNames` API. Requires further testing.
When aggregating spans into traces, a `trace-timeout` is evaluated as a way to mark a trace as completed. This variable should be big enough to avoid breaking traces and affecting...