如何暂停消费者在spring cloud kinesis流中消费消息

@Configuration
@EnableKinesis
public class KinesisConfig {

    @Value("${aws.accessKeyId}")
    private String accessKeyId;

    @Value("${aws.secretKey}")
    private String secretKey;

    @Value("${aws.region}")
    private String region;

    @Bean
    public AmazonKinesis amazonKinesis() {
        AWSCredentials awsCredentials = new BasicAWSCredentials(accessKeyId, secretKey);
        return AmazonKinesisClientBuilder.standard()
                .withCredentials(new AWSStaticCredentialsProvider(awsCredentials))
                .withRegion(region)
                .build();
    }

    @Bean
    public KinesisMessageDrivenChannelAdapter kinesisMessageDrivenChannelAdapter(
            AmazonKinesis amazonKinesis,
            KinesisMessageHandler kinesisMessageHandler) {
        KinesisMessageDrivenChannelAdapter adapter =
                new KinesisMessageDrivenChannelAdapter(amazonKinesis, "your-stream-name");
        adapter.setOutputChannel(kinesisMessageHandler.inputChannel());
        adapter.setCheckpointMode(CheckpointMode.manual);
        adapter.setListenerMode(ListenerMode.record);
        adapter.setStartTimeout(10000);
        adapter.setDescribeStreamRetries(1);
        adapter.setConcurrency(1);
        adapter.setPauseConsumersOnInit(true); // 暂停消费者初始化时的消息消费
        return adapter;
    }
}

@Component
public class KinesisMessageHandler {

    @Autowired
    private MessageChannel inputChannel;

    @KinesisListener
    public void handleMessage(String message) {
        // 处理消息的逻辑
        // 可以根据业务需求决定是否暂停消费者的消息消费
        inputChannel.pause();
    }

    public MessageChannel inputChannel() {
        return inputChannel;
    }
}