BindingsEndpoint kafka Stream spring boot

Question

我猜。它在本地电脑上运行良好，但在云 k8s 上运行不正常，请帮忙，谢谢

找不到“org.springframework.cloud.stream.endpoint.BindingsEndpoint”。 注入点有以下注释： - @org.springframework.beans.factory.annotation.Autowired（必需= true）

行动：

考虑在配置中定义“org.springframework.cloud.stream.endpoint.BindingsEndpoint”类型的 bean。

Answer 1

这可能不是最好的解决方案，但就我而言，这解决了问题。

    @Bean
    public BindingsEndpoint bindingsEndpoint(List<InputBindingLifecycle> inputBindings,
                                         List<OutputBindingLifecycle> outputBindings) {
            return new BindingsEndpoint(new BindingsLifecycleController(inputBindings, outputBindings));
    }