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

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 1732 天前的主题，其中的信息可能已经有所发展或是发生改变。

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 接口

3 条回复 • 2020-02-25 22:14:45 +08:00

WCID

2020-02-17 23:15:19 +08:00

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

hantsy

2020-02-24 16:21:52 +08:00

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

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

WCID

2020-02-25 22:14:45 +08:00

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