
KafkaListenerEndpointRegistry.destroy():
public void destroy() { for (MessageListenerontainer 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 接口
1 WCID OP 大佬们能不能解一下惑,是我哪里看漏了吗 |
2 hantsy 2020 年 2 月 24 日 不明白你要表达什么东西。 如果是你自己的或者其它第三方的 MessageListenerContainer Bean 可以实现 DisposableBean。 |