Code Review / policy / clamp.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 01a680b) | patch
Check each topic for Kafka health 33/141833/2
authoradheli.tavares <adheli.tavares@est.tech>
Thu, 14 Aug 2025 12:42:39 +0000 (13:42 +0100)
committeradheli.tavares <adheli.tavares@est.tech>
Thu, 14 Aug 2025 13:08:57 +0000 (14:08 +0100)
commitbf4217b4386b3c91a9e082d424012aecbf8f2eab
tree6a508871bf6d050bf33139f59baf75d5bc763774tree | snapshot
parent01a680b7867db965dc5467d44a1f5d7746337de0commit | diff
Check each topic for Kafka health

- as TopicManager does not shut down if kafka disconnects from
application, there is a need to check each topic individually.

Issue-ID: POLICY-5445
Change-Id: Ib9d194ce561debb8d9675ff0f971ab8b6eac7700
Signed-off-by: adheli.tavares <adheli.tavares@est.tech>
participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/BrokerStarter.java diff | blob | history
runtime-acm/src/main/java/org/onap/policy/clamp/acm/runtime/config/health/KafkaHealthIndicator.java diff | blob | history
runtime-acm/src/test/java/org/onap/policy/clamp/acm/runtime/main/rest/ActuatorControllerTest.java diff | blob | history
"policy-clamp"