如何使用Spring Cloud stream & Kafka Streams Binder暂停(开/关)流处理？

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-kafka-streams</artifactId>
</dependency>

spring:
  cloud:
    stream:
      bindings:
        input:
          destination: <input-topic>
        output:
          destination: <output-topic>
      kafka:
        streams:
          binder:
            configuration:
              application:
                id: <application-id>

@EnableBinding(Processor.class)
public class StreamProcessor {

    @StreamListener(Processor.INPUT)
    @SendTo(Processor.OUTPUT)
    public KStream<?, String> process(KStream<?, String> input) {
        // 处理消息的逻辑
        return input.mapValues(value -> value.toUpperCase());
    }
}

management:
  endpoints:
    web:
      exposure:
        include: health, info, pause, resume