[
https://issues.apache.org/jira/browse/CAMEL-16453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Claus Ibsen resolved CAMEL-16453.
---------------------------------
Fix Version/s: 3.7.4
Resolution: Fixed
> camel-zipkin - Incorrect spans created when using parallelProcessing with
> recipientList or multicast
> -----------------------------------------------------------------------------------------------------
>
> Key: CAMEL-16453
> URL: https://issues.apache.org/jira/browse/CAMEL-16453
> Project: Camel
> Issue Type: Bug
> Components: camel-zipkin
> Affects Versions: 3.9.0
> Reporter: Samrat Dhillon
> Priority: Major
> Fix For: 3.7.4, 3.10.0
>
>
> Incorrect spans (with incorrect parentId) are created by camel-zipkin when
> using *parallelProcessing* with recipientList or multicast e.g. consider the
> below route
> public void configure() throws Exception {
> restConfiguration()
> .component("netty-http")
> .host("0.0.0.0")
> .port(8081)
> .bindingMode(RestBindingMode.json);
> rest().get("/demo").produces("text/plain")
> .route().recipientList().method(CamelRoute.class).parallelProcessing();
> from("direct:a")
> .to("mock:c");
> from("direct:b")
> .to("mock:d");
> }
>
> The spans created for this are as follows. mock:c is supposed to have
> direct:a as the parent. But according to span information both mock:d and
> mock:c has parent "direct:b"
>
> {"traceId":"b2c6777c39c6ad9e","parentId":"1a139ce652082f20","id":"5322e166bb04c216","kind":"CLIENT","name":"mock://c","timestamp":1617630636132009,"duration":3564,"localEndpoint":\{"serviceName":"mock://c","ipv4":"192.168.56.1"},"tags":\{"camel.client.endpoint.url":"mock://c","camel.client.exchange.id":"62B17BA80F06ABA-0000000000000001","camel.client.exchange.pattern":"InOut"}}
> {"traceId":"b2c6777c39c6ad9e","parentId":"1a139ce652082f20","id":"1d23da2b33a4969c","kind":"CLIENT","name":"mock://d","timestamp":1617630636132011,"duration":3596,"localEndpoint":\{"serviceName":"mock://d","ipv4":"192.168.56.1"},"tags":\{"camel.client.endpoint.url":"mock://d","camel.client.exchange.id":"62B17BA80F06ABA-0000000000000002","camel.client.exchange.pattern":"InOut"}}
> {"traceId":"b2c6777c39c6ad9e","parentId":"e81809492156bfe3","id":"1a139ce652082f20","kind":"SERVER","name":"http://0.0.0.0:8081/demo","timestamp":1617630636130430,"duration":23706,"localEndpoint":\{"serviceName":"direct://b","ipv4":"192.168.56.1"},"tags":\{"camel.server.endpoint.url":"http://0.0.0.0:8081/demo?httpMethodRestrict=GET","camel.server.exchange.id":"62B17BA80F06ABA-0000000000000002","camel.server.exchange.pattern":"InOut"}}
> {"traceId":"b2c6777c39c6ad9e","parentId":"6ee96f0a005d441a","id":"53a64f899175a1be","kind":"SERVER","name":"http://0.0.0.0:8081/demo","timestamp":1617630636130428,"duration":23708,"localEndpoint":\{"serviceName":"direct://a","ipv4":"192.168.56.1"},"tags":\{"camel.server.endpoint.url":"http://0.0.0.0:8081/demo?httpMethodRestrict=GET","camel.server.exchange.id":"62B17BA80F06ABA-0000000000000001","camel.server.exchange.pattern":"InOut"}}
> {"traceId":"b2c6777c39c6ad9e","parentId":"b2c6777c39c6ad9e","id":"6ee96f0a005d441a","kind":"CLIENT","name":"direct://a","timestamp":1617630636125011,"duration":30645,"localEndpoint":\{"serviceName":"direct://a","ipv4":"192.168.56.1"},"tags":\{"camel.client.endpoint.url":"direct://b","camel.client.exchange.id":"62B17BA80F06ABA-0000000000000002","camel.client.exchange.pattern":"InOut"}}
> {"traceId":"b2c6777c39c6ad9e","parentId":"b2c6777c39c6ad9e","id":"e81809492156bfe3","kind":"CLIENT","name":"direct://b","timestamp":1617630636125011,"duration":30652,"localEndpoint":\{"serviceName":"direct://b","ipv4":"192.168.56.1"},"tags":\{"camel.client.endpoint.url":"direct://a","camel.client.exchange.id":"62B17BA80F06ABA-0000000000000001","camel.client.exchange.pattern":"InOut"}}
> {"traceId":"b2c6777c39c6ad9e","id":"b2c6777c39c6ad9e","kind":"SERVER","name":"http://0.0.0.0:8081/demo","timestamp":1617630636095939,"duration":61810,"localEndpoint":\{"serviceName":"rest://get:/demo","ipv4":"192.168.56.1"},"tags":\{"camel.server.endpoint.url":"http://0.0.0.0:8081/demo?httpMethodRestrict=GET","camel.server.exchange.id":"62B17BA80F06ABA-0000000000000000","camel.server.exchange.pattern":"InOut"}}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)