Good day everyone.
I have a quarkus/camel route that picks up a string message from a KAFKA topic
and sends it on to a REST service.
It currently looks as follows:
from(kafka(registrationTopicName)
.brokers(kafkaBroker)
.clientId(kafkaClientId)
.groupId(groupId)
.keyDeserializer(keyDeserializer)
.valueDeserializer(valueDeserializer)
.autoOffsetReset(offset))
.log("Registration Event received: ${body}")
.to("rest://post:regEvent?host={{fms.registration.restservice.endpoint}}")
.log("After calling REST service: ${body}");
The scenarios I want to deal with is as follows:
1. The target service is down for some reason. I would like the route to retry
every x amount of minutes for a maximum of y number of times. If still failing
the route should throw an exception and stop completely until the sysadmins can
get the target system back up and running.
2. the target service is up but for some internal reason cannot process the
message right now. Behaviour should be exactly the same as with 1 above.
Does anyone have any examples of this kind of scenario in quarkus/camel?
Many thanks.
Elmar
Elmar Matthee
INFORMATION TECHNOLOGY (Institutional Software Solutions)
University of Stellenbosch
South Africa
Tel: +27 21 808 3580 | map
Cel: +27 82 829 8417
Fax: +27 21 808 4102
--
Meddle not in the affairs of dragons puny mortal
for thou art crunchy and taste good with ketchup.
[https://www.sun.ac.za/productionfooter/email/ProductionFooter.jpg]<https://www.sun.ac.za/english/about-us/strategic-documents>
The integrity and confidentiality of this email are governed by these terms.
Disclaimer<https://www.sun.ac.za/emaildisclaimer/default.aspx>
Die integriteit en vertroulikheid van hierdie e-pos word deur die volgende
bepalings bereël.
Vrywaringsklousule<https://www.sun.ac.za/emaildisclaimer/default.aspx>
