Spring Kafka 疑惑：默认情况下， endpoint registry 的 destroy 方法有啥卵用吗

[WCID]

KafkaListenerEndpointRegistry.destroy():

public void destroy() {
    for (MessageListenerContainer listenerContainer : getListenerContainers()) {
        if (listenerContainer instanceof DisposableBean) {
            try {
                ((DisposableBean) listenerContainer).destroy();
            } catch (Exception ex) {
                this.logger.warn("Failed to destroy message listener container", ex);
            }
        }
    }
}

貌似 SpringKafka 中实现了 MessageListenerContainer 接口的类都没有实现 DisposableBean 接口

[WCID]

大佬们能不能解一下惑，是我哪里看漏了吗

[hantsy]

不明白你要表达什么东西。

如果是你自己的或者其它第三方的 MessageListenerContainer Bean 可以实现 DisposableBean。

[WCID]

@hantsy 为什么框架里的 MessageListenerContainer 自己不实现呢