Skip to content

Commit 07c6be8

Browse files
dcotfrgsmet
authored andcommitted
Resolves 40315 & 41432 issues
(cherry picked from commit 614d0f0)
1 parent 2dfa186 commit 07c6be8

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/devui/KafkaStreamsJsonRPCService.java

+8-2
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
import java.util.regex.Pattern;
88
import java.util.stream.Stream;
99

10+
import jakarta.enterprise.inject.Instance;
1011
import jakarta.inject.Inject;
1112

1213
import org.apache.kafka.streams.Topology;
@@ -16,11 +17,16 @@
1617

1718
public class KafkaStreamsJsonRPCService {
1819
@Inject
19-
Topology topology;
20+
Instance<Topology> topologyProvider;
2021

2122
@NonBlocking
2223
public JsonObject getTopology() {
23-
return parseTopologyDescription(topology.describe() != null ? topology.describe().toString() : "");
24+
var topologyDescription = "";
25+
if (topologyProvider.isResolvable()) {
26+
final var describe = topologyProvider.get().describe();
27+
topologyDescription = describe != null ? describe.toString() : "";
28+
}
29+
return parseTopologyDescription(topologyDescription);
2430
}
2531

2632
JsonObject parseTopologyDescription(String topologyDescription) {

0 commit comments

Comments
 (0)