Kafka Streams 拓扑可视化

Kafka Streams binder 提供以下 actuator 端点,用于检索拓扑描述,您可以使用这些描述通过外部工具可视化拓扑。

/actuator/kafkastreamstopology

/actuator/kafkastreamstopology/<application-id of the processor>

您需要包含 Spring Boot 的 actuator 和 web 依赖才能访问这些端点。此外,您还需要将 kafkastreamstopology 添加到 management.endpoints.web.exposure.include 属性中。默认情况下,kafkastreamstopology 端点是禁用的。