casdtodtenhoefer opened a new issue, #3785:
URL: https://github.com/apache/camel-k/issues/3785
Hello guys,
we encountered a very strange behaviour in our Camel-K integrations. Our
body consits of an list with about 10.000 entries and we try to do an parallel
split to send them to kafka. In our log we can see, that there are 10 threads,
but they are running sequentially. The second thread starts after the first one
finishes. We thing that this could be a problem regarding camel-k, because we
already have a kind of similar route built with Camel Spring Boot and it's
running as intended.
Here are our used routes:
`camelRouteBuilder
.from("direct:" + getRouteId())
.routeId(getRouteId())
.split(camelRouteBuilder.body()).streaming().parallelProcessing()
.to(getRouteId()+"-send")
.end()
.to("direct:" + targetRouteName)
;
camelRouteBuilder
.from("direct:" + getRouteId() + "-send")
.routeId(getRouteId()+"-send")
.removeHeaders("*")
.setHeader("kafka.KEY",
camelRouteBuilder.simple(getKafkaKey()))
.to("kafka-producer:{{kafka.topic}}")
//logging route
.to("direct:" + getProducerLogging().endpoint)
;`
Is this a known issue or am I doing something wrong?
Best regards,
Danny
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
