Skip to content

Commit 9ce5d81

Browse files
committed
fix(server): health status must return DOWN when streams instance stop on failure
Resolves: #54
1 parent 9113d80 commit 9ce5d81

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

azkarra-server/src/main/java/io/streamthoughts/azkarra/http/health/internal/StreamsHealthIndicator.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@
3030

3131
import java.util.List;
3232
import java.util.Map;
33+
import java.util.Optional;
3334
import java.util.TreeMap;
3435
import java.util.stream.Collectors;
3536

@@ -75,13 +76,18 @@ public Health getHealth() {
7576

7677
private void setHealthStatus(final KafkaStreamsContainer container,
7778
final Health.Builder builder) {
78-
State value = container.state().value();
79+
final State value = container.state().value();
80+
final Optional<Throwable> exception = container.exception();
7981
switch (value) {
8082
case RUNNING :
8183
builder.up();
82-
break;
84+
break;
8385
case ERROR :
8486
builder.down();
87+
exception.ifPresent(builder::withException);
88+
break;
89+
case NOT_RUNNING:
90+
exception.ifPresentOrElse(e -> builder.down().withException(e), builder::unknown);
8591
break;
8692
default:
8793
builder.unknown();

0 commit comments

Comments
 (0)