Spring cloud streamKafka暂停/恢复绑定

Question

我们正在使用spring cloude stream 2.0

现在在Spring Cloud stream 2.0中，有一种使用执行器管理绑定器生命周期的方法：绑定可视化和控制

是否可以从代码控制绑定器的生命周期，这意味着在目标服务器关闭的情况下，暂停绑定器，当它启动时，恢复？

Answer 1

对不起，我误解了你的问题。

您可以自动连接BindingsEndpoint，但不幸的是，它的State枚举是私有的，因此您无法以编程方式调用ChangeState（）。

我为此打开了一个问题。

编辑

你可以用反射来做，但有点难看。。。

@SpringBootApplication
@EnableBinding(Sink.class)
public class So53476384Application {

    public static void main(String[] args) {
        SpringApplication.run(So53476384Application.class, args);
    }

    @Autowired
    BindingsEndpoint binding;

    @Bean
    public ApplicationRunner runner() {
        return args -> {
            Class<?> clazz = ClassUtils.forName("org.springframework.cloud.stream.endpoint.BindingsEndpoint$State",
                    So53476384Application.class.getClassLoader());
            ReflectionUtils.doWithMethods(BindingsEndpoint.class, method -> {
                try {
                    method.invoke(this.binding, "input", clazz.getEnumConstants()[2]); // PAUSE
                }
                catch (InvocationTargetException e) {
                    e.printStackTrace();
                }
            }, method -> method.getName().equals("changeState"));
        };
    }

    @StreamListener(Sink.INPUT)
    public void listen(String in) {

    }

}