Kafka Streams binder 中的繫結視覺化和控制
從 3.1.2 版本開始，Kafka Streams binder 支援繫結視覺化和控制。支援的生命週期階段只有 STOPPED 和 STARTED。生命週期階段 PAUSED 和 RESUMED 在 Kafka Streams binder 中不可用。
為了啟用繫結視覺化和控制功能，應用需要包含以下兩個依賴。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>如果你偏好使用 webflux，則可以包含 spring-boot-starter-webflux 代替標準的 web 依賴。
此外，你還需要設定以下屬性
management.endpoints.web.exposure.include=bindings為了進一步說明此特性，我們使用以下應用作為指導
@SpringBootApplication
public class KafkaStreamsApplication {
public static void main(String[] args) {
SpringApplication.run(KafkaStreamsApplication.class, args);
}
@Bean
public Consumer<KStream<String, String>> consumer() {
return s -> s.foreach((key, value) -> System.out.println(value));
}
@Bean
public Function<KStream<String, String>, KStream<String, String>> function() {
return ks -> ks;
}
}正如我們所見，該應用包含兩個 Kafka Streams 函式 - 一個是消費者，另一個是函式。消費者繫結預設命名為 consumer-in-0。類似地，對於函式，輸入繫結是 function-in-0，輸出繫結是 function-out-0。
應用啟動後，我們可以使用以下繫結端點找到關於繫結的詳細資訊。
curl https://:8080/actuator/bindings | jq .
[
{
"bindingName": "consumer-in-0",
"name": "consumer-in-0",
"group": "consumer-applicationId",
"pausable": false,
"state": "running",
"paused": false,
"input": true,
"extendedInfo": {}
},
{
"bindingName": "function-in-0",
"name": "function-in-0",
"group": "function-applicationId",
"pausable": false,
"state": "running",
"paused": false,
"input": true,
"extendedInfo": {}
},
{
"bindingName": "function-out-0",
"name": "function-out-0",
"group": "function-applicationId",
"pausable": false,
"state": "running",
"paused": false,
"input": false,
"extendedInfo": {}
}
]關於所有三個繫結的詳細資訊可在上面找到。
現在讓我們停止 consumer-in-0 繫結。
curl -d '{"state":"STOPPED"}' -H "Content-Type: application/json" -X POST https://:8080/actuator/bindings/consumer-in-0此時，將不會透過此繫結接收任何記錄。
再次啟動繫結。
curl -d '{"state":"STARTED"}' -H "Content-Type: application/json" -X POST https://:8080/actuator/bindings/consumer-in-0當一個函式存在多個繫結時，在這些繫結中的任何一個上呼叫這些操作都將生效。這是因為一個函式上的所有繫結都由同一個 StreamsBuilderFactoryBean 支援。因此，對於上面的函式，function-in-0 或 function-out-0 都可以工作。
