Camel 4.15 - resilience4j-micrometer extension

[davsclaus]

Describe the feature here

Add a new extension that setup micrometer for resilience4j like its done for CSB
https://github.com/apache/camel-spring-boot/blob/main/components-starter/camel-resilience4j-micrometer-starter/src/main/java/org/apache/camel/component/resilience4j/micrometer/Resilience4jMicrometerAutoConfiguration.java

https://issues.apache.org/jira/browse/CAMEL-22392

[jamesnetherton]

We don't actually support resilience4j for CQ (not sure if we ever should TBH). The preferred fault tolerance extension is camel-quarkus-microprofile-fault-tolerance. SmallRye Fault Tolerance already provides us with some OOTB integration with Micrometer.

Not sure if we want to create something in Camel like camel-microprofile-fault-tolerance-micrometer with similar metric setup to camel-resilience4j-micrometer?

[davsclaus]

Okay thanks.

About camel-microprofile-fault-tolerance-micrometer then that would only be needed if MP fault tolerance exposes metrics and make it as easy as it was with resilience4j. But if it does then it would be nice as understanding the state of these CBs can be tricky if there is no visibility.

[jamesnetherton]

I added Micrometer to our microprofile-fault-tolerance tests just to see what metrics get produced.

Here's what I got from /q/metrics:

# TYPE ft_circuitbreaker_calls counter
# HELP ft_circuitbreaker_calls
ft_circuitbreaker_calls_total{circuitBreakerResult="failure",method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithCircuitBreaker"} 1.0
ft_circuitbreaker_calls_total{circuitBreakerResult="circuitBreakerOpen",method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithCircuitBreaker"} 0.0
ft_circuitbreaker_calls_total{circuitBreakerResult="success",method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithCircuitBreaker"} 1.0
# TYPE ft_timer_scheduled gauge
# HELP ft_timer_scheduled
ft_timer_scheduled{id="1"} 0.0
# TYPE ft_timeout_executionDuration_seconds summary
# HELP ft_timeout_executionDuration_seconds
ft_timeout_executionDuration_seconds_count{method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithDelay"} 2.0
ft_timeout_executionDuration_seconds_sum{method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithDelay"} 0.251534208
# TYPE ft_timeout_executionDuration_seconds_max gauge
# HELP ft_timeout_executionDuration_seconds_max
ft_timeout_executionDuration_seconds_max{method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithDelay"} 0.251451208
# TYPE ft_timeout_calls counter
# HELP ft_timeout_calls
ft_timeout_calls_total{method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithDelay",timedOut="true"} 1.0
ft_timeout_calls_total{method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithDelay",timedOut="false"} 1.0
# TYPE ft_circuitbreaker_state_total_seconds gauge
# HELP ft_circuitbreaker_state_total_seconds
ft_circuitbreaker_state_total_seconds{method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithCircuitBreaker",state="halfOpen"} 0.0095385
ft_circuitbreaker_state_total_seconds{method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithCircuitBreaker",state="closed"} 6.462425749
ft_circuitbreaker_state_total_seconds{method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithCircuitBreaker",state="open"} 1.45334E-4
# TYPE ft_invocations counter
# HELP ft_invocations
ft_invocations_total{fallback="notDefined",method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithCircuitBreaker",result="valueReturned"} 1.0
ft_invocations_total{fallback="applied",method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithFallback",result="exceptionThrown"} 0.0
ft_invocations_total{fallback="notApplied",method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithFallback",result="valueReturned"} 1.0
ft_invocations_total{fallback="notDefined",method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithDelay",result="valueReturned"} 1.0
ft_invocations_total{fallback="applied",method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithFallback",result="valueReturned"} 1.0
ft_invocations_total{fallback="notDefined",method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithCircuitBreaker",result="exceptionThrown"} 1.0
ft_invocations_total{fallback="notApplied",method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithFallback",result="exceptionThrown"} 0.0
ft_invocations_total{fallback="notDefined",method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithDelay",result="exceptionThrown"} 1.0
# TYPE ft_circuitbreaker_state_current gauge
# HELP ft_circuitbreaker_state_current
ft_circuitbreaker_state_current{method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithCircuitBreaker",state="halfOpen"} 0.0
ft_circuitbreaker_state_current{method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithCircuitBreaker",state="closed"} 1.0
ft_circuitbreaker_state_current{method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithCircuitBreaker",state="open"} 0.0
# TYPE ft_circuitbreaker_opened counter
# HELP ft_circuitbreaker_opened
ft_circuitbreaker_opened_total{method="org.apache.camel.quarkus.component.microprofile.it.faulttolerance.GreetingBean.greetWithCircuitBreaker"} 1.0

[davsclaus]

Ah that is very good