如何创建spring bean，即“Kafka sink”bean，以刷新来自配置服务器的上下文

Question

这是我的代码

@EnableBinding(Sink.class)
public class ApiApplication {
......


@StreamListener(Sink.INPUT)
    public void configRefreshSink(RefreshRemoteApplicationEvent event) {
        log.info("ApiApplication.configRefreshSink() called");
        String applicationToRefreshContext = event.getDestinationService();
        if (applicationToRefreshContext.startsWith(this.applicationName)) {
            Set<String> keys = contextRefresher.refresh();
            log.info("Received remote refresh request. Keys refreshed: " + keys);
        }
        log.info("Received remote refresh request. Destination: " + event.getDestinationService());
    }
}

这些是我得到的错误

Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.context.support.ClassPathXmlApplicationContext]: Constructor threw exception; nested exception is java.lang.NoSuchMethodError: org/springframework/util/Assert.notNull(Ljava/lang/Object;Ljava/util/function/Supplier;)V (loaded from file:xxxxx/repository/org/springframework/spring-core/4.3.22.RELEASE/spring-core-4.3.22.RELEASE.jar by

Answer 1

1. 错误

nosuchmethoderror：org/springframework/util/assert.notnull（ljava/lang/object；ljava/util/function/supplier；）V

意味着Spring Framework的版本太旧了--该方法是在Spring Framework 5.0中添加的